|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.activemq.transport.TransportChannelSupport
org.activemq.transport.vm.VmTransportChannel
org.activemq.transport.peer.PeerTransportChannel
A PeerTransportChannel
creates an embedded broker and networks peers together to form a P-2-P network.
By default, PeerTransportChannel
uses discovery to locate other peers, and uses a well known service
name on the discovery
An example of the expected format is: peer://development.net
where development.net is the service name
used in discovery
Field Summary | |
protected BrokerConnector |
brokerConnector
|
protected String |
brokerConnectorURI
|
protected String |
brokerName
|
protected TransportChannel |
channel
|
protected static String |
DEFAULT_BROKER_CONNECTOR_URI
|
protected String |
discoveryURI
|
protected boolean |
doDiscovery
|
protected String |
peerURIs
|
protected boolean |
persistent
|
protected boolean |
remote
|
protected String |
remotePassword
|
protected String |
remoteUserName
|
protected String |
serviceName
|
protected WireFormat |
wireFormat
|
Fields inherited from class org.activemq.transport.TransportChannelSupport |
cachingEnabled, currentWireFormat, noDelay, pendingStop, transportConnected, usedInternally |
Constructor Summary | |
protected |
PeerTransportChannel(WireFormat wireFormat,
String serviceName)
Construct a PeerTransportChannel |
Method Summary | |
protected NetworkConnector |
createNetworkConnector(BrokerContainer container)
Create a NetworkConnector |
String |
getBrokerConnectorURI()
|
String |
getBrokerName()
|
String |
getDiscoveryURI()
|
BrokerConnector |
getEmbeddedBrokerConnector()
Some transports that rely on an embedded broker need to create the connector used by the broker |
String |
getPeerURIs()
|
String |
getRemotePassword()
|
String |
getRemoteUserName()
|
String |
getServiceName()
|
WireFormat |
getWireFormat()
Get the current wireformat used by this channel |
boolean |
isDoDiscovery()
|
boolean |
isPersistent()
|
boolean |
isRemote()
|
boolean |
isTransportConnected()
|
boolean |
requiresEmbeddedBroker()
Some transports rely on an embedded broker (beer based protocols) |
void |
setBrokerConnectorURI(String brokerConnectorURI)
|
void |
setBrokerName(String brokerName)
|
void |
setDiscoveryURI(String discoveryURI)
|
void |
setDoDiscovery(boolean doDiscovery)
|
void |
setPeerURIs(String peerURIs)
|
void |
setPersistent(boolean persistent)
|
void |
setRemote(boolean remote)
|
void |
setRemotePassword(String remotePassword)
|
void |
setRemoteUserName(String remoteUserName)
|
void |
setServiceName(String serviceName)
|
void |
setWireFormat(WireFormat wireFormat)
set the wire format to be used by this channel |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
protected static final String DEFAULT_BROKER_CONNECTOR_URI
protected WireFormat wireFormat
protected TransportChannel channel
protected String discoveryURI
protected String remoteUserName
protected String remotePassword
protected String brokerName
protected boolean doDiscovery
protected String peerURIs
protected String brokerConnectorURI
protected String serviceName
protected BrokerConnector brokerConnector
protected boolean remote
protected boolean persistent
Constructor Detail |
protected PeerTransportChannel(WireFormat wireFormat, String serviceName) throws JMSException
wireFormat
- serviceName
-
JMSException
Method Detail |
public boolean isTransportConnected()
isTransportConnected
in interface TransportChannel
isTransportConnected
in class TransportChannelSupport
public boolean requiresEmbeddedBroker()
requiresEmbeddedBroker
in interface TransportChannel
requiresEmbeddedBroker
in class TransportChannelSupport
public BrokerConnector getEmbeddedBrokerConnector() throws JMSException
getEmbeddedBrokerConnector
in interface TransportChannel
getEmbeddedBrokerConnector
in class TransportChannelSupport
JMSException
protected NetworkConnector createNetworkConnector(BrokerContainer container)
container
-
public String getDiscoveryURI()
public void setDiscoveryURI(String discoveryURI)
discoveryURI
- The brokerDiscoveryURI to set.public String getBrokerName()
public void setBrokerName(String brokerName)
brokerName
- The brokerName to set.public boolean isDoDiscovery()
public void setDoDiscovery(boolean doDiscovery)
doDiscovery
- The doDiscovery to set.public WireFormat getWireFormat()
TransportChannelSupport
getWireFormat
in interface TransportChannel
getWireFormat
in class TransportChannelSupport
public void setWireFormat(WireFormat wireFormat)
TransportChannelSupport
setWireFormat
in interface TransportChannel
setWireFormat
in class TransportChannelSupport
wireFormat
- The wireFormat to set.public String getRemotePassword()
public void setRemotePassword(String remotePassword)
remotePassword
- The remotePassword to set.public String getRemoteUserName()
public void setRemoteUserName(String remoteUserName)
remoteUserName
- The remoteUserName to set.public String getBrokerConnectorURI()
public void setBrokerConnectorURI(String brokerConnectorURI)
brokerConnectorURI
- The brokerConnectorURI to set.public String getPeerURIs()
public void setPeerURIs(String peerURIs)
peerURIs
- The peerURIs to set.public String getServiceName()
public void setServiceName(String serviceName)
serviceName
- The serviceName to set.public boolean isRemote()
public void setRemote(boolean remote)
remote
- The remote to set.public boolean isPersistent()
public void setPersistent(boolean persistent)
persistent
- The persistent to set.
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |