blob: ff0c007a60482d23fa676cb7b103ff5c12669a88 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
|
package org.apache.qpid.server.protocol;
import org.apache.qpid.protocol.ProtocolEngine;
import org.apache.qpid.protocol.ProtocolEngineFactory;
import org.apache.qpid.server.registry.ApplicationRegistry;
import org.apache.qpid.server.virtualhost.VirtualHostRegistry;
import org.apache.qpid.transport.NetworkDriver;
public class AMQProtocolEngineFactory implements ProtocolEngineFactory
{
private VirtualHostRegistry _vhosts;
public AMQProtocolEngineFactory()
{
this(1);
}
public AMQProtocolEngineFactory(Integer port)
{
_vhosts = ApplicationRegistry.getInstance(port).getVirtualHostRegistry();
}
public ProtocolEngine newProtocolEngine(NetworkDriver networkDriver)
{
return new AMQProtocolEngine(_vhosts, networkDriver);
}
}
|