|
|||||||||||
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 java.lang.String |
brokerConnectorURI
|
protected java.lang.String |
brokerName
|
protected TransportChannel |
channel
|
protected static java.lang.String |
DEFAULT_BROKER_CONNECTOR_URI
|
protected java.lang.String |
discoveryURI
|
protected boolean |
doDiscovery
|
protected java.lang.String |
peerURIs
|
protected boolean |
persistent
|
protected boolean |
remote
|
protected java.lang.String |
remotePassword
|
protected java.lang.String |
remoteUserName
|
protected java.lang.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,
java.lang.String serviceName)
Construct a PeerTransportChannel |
Method Summary | |
protected NetworkConnector |
createNetworkConnector(BrokerContainer container)
Create a NetworkConnector |
java.lang.String |
getBrokerConnectorURI()
|
java.lang.String |
getBrokerName()
|
java.lang.String |
getDiscoveryURI()
|
BrokerConnector |
getEmbeddedBrokerConnector()
Some transports that rely on an embedded broker need to create the connector used by the broker |
java.lang.String |
getPeerURIs()
|
java.lang.String |
getRemotePassword()
|
java.lang.String |
getRemoteUserName()
|
java.lang.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(java.lang.String brokerConnectorURI)
|
void |
setBrokerName(java.lang.String brokerName)
|
void |
setDiscoveryURI(java.lang.String discoveryURI)
|
void |
setDoDiscovery(boolean doDiscovery)
|
void |
setPeerURIs(java.lang.String peerURIs)
|
void |
setPersistent(boolean persistent)
|
void |
setRemote(boolean remote)
|
void |
setRemotePassword(java.lang.String remotePassword)
|
void |
setRemoteUserName(java.lang.String remoteUserName)
|
void |
setServiceName(java.lang.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 java.lang.String DEFAULT_BROKER_CONNECTOR_URI
protected WireFormat wireFormat
protected TransportChannel channel
protected java.lang.String discoveryURI
protected java.lang.String remoteUserName
protected java.lang.String remotePassword
protected java.lang.String brokerName
protected boolean doDiscovery
protected java.lang.String peerURIs
protected java.lang.String brokerConnectorURI
protected java.lang.String serviceName
protected BrokerConnector brokerConnector
protected boolean remote
protected boolean persistent
Constructor Detail |
protected PeerTransportChannel(WireFormat wireFormat, java.lang.String serviceName) throws javax.jms.JMSException
wireFormat
- serviceName
-
javax.jms.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 javax.jms.JMSException
getEmbeddedBrokerConnector
in interface TransportChannel
getEmbeddedBrokerConnector
in class TransportChannelSupport
javax.jms.JMSException
protected NetworkConnector createNetworkConnector(BrokerContainer container)
container
-
public java.lang.String getDiscoveryURI()
public void setDiscoveryURI(java.lang.String discoveryURI)
discoveryURI
- The brokerDiscoveryURI to set.public java.lang.String getBrokerName()
public void setBrokerName(java.lang.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 java.lang.String getRemotePassword()
public void setRemotePassword(java.lang.String remotePassword)
remotePassword
- The remotePassword to set.public java.lang.String getRemoteUserName()
public void setRemoteUserName(java.lang.String remoteUserName)
remoteUserName
- The remoteUserName to set.public java.lang.String getBrokerConnectorURI()
public void setBrokerConnectorURI(java.lang.String brokerConnectorURI)
brokerConnectorURI
- The brokerConnectorURI to set.public java.lang.String getPeerURIs()
public void setPeerURIs(java.lang.String peerURIs)
peerURIs
- The peerURIs to set.public java.lang.String getServiceName()
public void setServiceName(java.lang.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 |