|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||
java.lang.Objectorg.activemq.broker.impl.BrokerContainerImpl
Represents the ActiveMQ JMS Broker which typically has one or many connectors
| Field Summary | |
static java.lang.String |
DISABLE_CLEAN_SHUTDOWN_PROPERTY
|
| Constructor Summary | |
BrokerContainerImpl()
|
|
BrokerContainerImpl(Broker broker,
BrokerContext context)
|
|
BrokerContainerImpl(java.lang.String brokerName)
|
|
BrokerContainerImpl(java.lang.String brokerName,
BrokerContext context)
|
|
BrokerContainerImpl(java.lang.String brokerName,
BrokerContext context,
MemoryBoundedObjectManager memoryManager)
|
|
BrokerContainerImpl(java.lang.String brokerName,
MemoryBoundedObjectManager memoryManager)
|
|
BrokerContainerImpl(java.lang.String brokerName,
PersistenceAdapter persistenceAdapter)
|
|
BrokerContainerImpl(java.lang.String brokerName,
PersistenceAdapter persistenceAdapter,
BrokerContext context)
|
|
BrokerContainerImpl(java.lang.String brokerName,
java.lang.String clusterName)
|
|
BrokerContainerImpl(java.lang.String brokerName,
java.lang.String clusterName,
BrokerContext context)
|
|
BrokerContainerImpl(java.lang.String brokerName,
java.lang.String clusterName,
PersistenceAdapter persistenceAdapter,
BrokerContext context)
|
|
| Method Summary | |
void |
acknowledgeMessage(BrokerClient client,
MessageAck ack)
Acknowledge reciept of a message |
void |
addConnector(BrokerConnector connector)
Called when a new connector is added to this container |
void |
addConnector(java.lang.String bindAddress)
Adds a new transport connector for the given bind address |
void |
addConnector(java.lang.String bindAddress,
WireFormat wireFormat)
Adds a new transport connector for the given bind address and wire format |
void |
addConnector(TransportServerChannel transportConnector)
Adds a new transport connector for the given transportConnector |
NetworkConnector |
addNetworkConnector()
Adds a new network connector |
void |
addNetworkConnector(NetworkConnector connector)
Adds a new network connector |
NetworkConnector |
addNetworkConnector(java.lang.String uri)
Adds a new network connector for the given URI |
protected void |
addShutdownHook()
|
void |
capacityChanged(CapacityMonitorEvent event)
Update any message producers about our capacity to handle messages |
protected void |
checkBrokerSet()
|
void |
commitTransaction(BrokerClient client,
ActiveMQXid xid,
boolean onePhase)
Commit an XA transaction. |
void |
commitTransaction(BrokerClient client,
java.lang.String transactionId)
Commit a transaction |
protected void |
containerShutdown()
Causes a clean shutdown of the container when the VM is being shut down |
protected java.util.Map |
createLocalDiscoveryDetails()
|
void |
deregisterConnection(BrokerClient client,
ConnectionInfo info)
un-registers a Connection |
void |
deregisterMessageConsumer(BrokerClient client,
ConsumerInfo info)
De-register a MessageConsumer from the Broker |
void |
deregisterMessageProducer(BrokerClient client,
ProducerInfo info)
De-register a MessageProducer from the Broker |
void |
deregisterRemoteClientID(java.lang.String remoteClientID)
deregister a remote clientID |
void |
deregisterSession(BrokerClient client,
SessionInfo info)
De-register a client-side Session from the Broker (used for monitoring) |
void |
durableUnsubscribe(BrokerClient client,
DurableUnsubscribe ds)
Command to delete a durable topic subscription |
Broker |
getBroker()
|
DiscoveryAgent |
getDiscoveryAgent()
Returns the discovery agent if one is available or null if discovery is not enabled |
protected java.lang.String |
getLocalBrokerName()
|
protected java.lang.String |
getLocalConnectionURL()
|
java.util.List |
getNetworkConnectors()
Returns a list of NetworkConnector
instances used to communicate with the network of Broker instances |
PersistenceAdapter |
getPersistenceAdapter()
Returns the persistence adapter |
ActiveMQXid[] |
getPreparedTransactions(BrokerClient client)
Gets the prepared XA transactions. |
RedeliveryPolicy |
getRedeliveryPolicy()
|
SecurityAdapter |
getSecurityAdapter()
Returns the security adapter used to authenticate and authorize access to JMS resources |
java.util.List |
getTransportConnectors()
Returns the transport connectors used to communicate with clients |
int |
prepareTransaction(BrokerClient client,
ActiveMQXid xid)
Prepare an XA transaction. |
void |
registerConnection(BrokerClient client,
ConnectionInfo info)
registers a new Connection |
void |
registerMessageConsumer(BrokerClient client,
ConsumerInfo info)
Registers a MessageConsumer |
void |
registerMessageProducer(BrokerClient client,
ProducerInfo info)
Registers a MessageProducer |
void |
registerRemoteClientID(java.lang.String remoteClientID)
register a remote clientID |
void |
registerSession(BrokerClient client,
SessionInfo info)
Register a client-side Session (used for Monitoring) |
void |
removeConnector(BrokerConnector connector)
Called when a connector is removed to this container |
void |
removeNetworkConnector(NetworkConnector connector)
Removes the given network connector |
void |
rollbackTransaction(BrokerClient client,
ActiveMQXid xid)
Rollback an XA transaction. |
void |
rollbackTransaction(BrokerClient client,
java.lang.String transactionId)
Rollback a transacton |
void |
sendMessage(BrokerClient client,
ActiveMQMessage message)
Send a non-transacted message to the Broker |
void |
setDiscoveryAgent(DiscoveryAgent discoveryAgent)
|
void |
setNetworkConnectors(java.util.List networkConnectors)
|
void |
setPersistenceAdapter(PersistenceAdapter persistenceAdapter)
|
void |
setRedeliveryPolicy(RedeliveryPolicy redeliveryPolicy)
|
void |
setSecurityAdapter(SecurityAdapter securityAdapter)
Sets the security adapter used to authenticate and authorize access to JMS resources |
void |
setTransportConnectors(java.util.List transportConnectors)
|
void |
start()
start the Container |
void |
startTransaction(BrokerClient client,
ActiveMQXid xid)
Start an XA transaction. |
void |
startTransaction(BrokerClient client,
java.lang.String transactionId)
Start a transaction from the Client session |
void |
stop()
Stop the Container |
| Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Field Detail |
public static final java.lang.String DISABLE_CLEAN_SHUTDOWN_PROPERTY
| Constructor Detail |
public BrokerContainerImpl()
public BrokerContainerImpl(java.lang.String brokerName)
public BrokerContainerImpl(java.lang.String brokerName,
MemoryBoundedObjectManager memoryManager)
public BrokerContainerImpl(java.lang.String brokerName,
java.lang.String clusterName)
public BrokerContainerImpl(java.lang.String brokerName,
PersistenceAdapter persistenceAdapter)
public BrokerContainerImpl(java.lang.String brokerName,
BrokerContext context)
public BrokerContainerImpl(java.lang.String brokerName,
BrokerContext context,
MemoryBoundedObjectManager memoryManager)
public BrokerContainerImpl(java.lang.String brokerName,
java.lang.String clusterName,
BrokerContext context)
public BrokerContainerImpl(java.lang.String brokerName,
PersistenceAdapter persistenceAdapter,
BrokerContext context)
public BrokerContainerImpl(java.lang.String brokerName,
java.lang.String clusterName,
PersistenceAdapter persistenceAdapter,
BrokerContext context)
public BrokerContainerImpl(Broker broker,
BrokerContext context)
broker - | Method Detail |
public void start()
throws javax.jms.JMSException
start in interface Servicejavax.jms.JMSException
public void stop()
throws javax.jms.JMSException
stop in interface Servicejavax.jms.JMSException
public void registerConnection(BrokerClient client,
ConnectionInfo info)
throws javax.jms.JMSException
registerConnection in interface BrokerContainerclient - info - infomation about the client-side Connection
javax.jms.InvalidClientIDException - if the ClientID of the Connection is a duplicate
javax.jms.JMSException
public void deregisterConnection(BrokerClient client,
ConnectionInfo info)
throws javax.jms.JMSException
deregisterConnection in interface BrokerContainerclient - info - infomation about the client-side Connection
javax.jms.JMSException
public void registerMessageConsumer(BrokerClient client,
ConsumerInfo info)
throws javax.jms.JMSException
registerMessageConsumer in interface BrokerContainerclient - info -
javax.jms.JMSException
javax.jms.JMSSecurityException - if client authentication fails for the Destination the Consumer applies for
public void deregisterMessageConsumer(BrokerClient client,
ConsumerInfo info)
throws javax.jms.JMSException
deregisterMessageConsumer in interface BrokerContainerclient - info -
javax.jms.JMSException
public void registerMessageProducer(BrokerClient client,
ProducerInfo info)
throws javax.jms.JMSException
registerMessageProducer in interface BrokerContainerclient - info -
javax.jms.JMSException
javax.jms.JMSSecurityException - if client authentication fails for the Destination the Consumer applies for
public void deregisterMessageProducer(BrokerClient client,
ProducerInfo info)
throws javax.jms.JMSException
deregisterMessageProducer in interface BrokerContainerclient - info -
javax.jms.JMSException
public void registerSession(BrokerClient client,
SessionInfo info)
throws javax.jms.JMSException
registerSession in interface BrokerContainerclient - info -
javax.jms.JMSException
public void deregisterSession(BrokerClient client,
SessionInfo info)
throws javax.jms.JMSException
deregisterSession in interface BrokerContainerclient - info -
javax.jms.JMSException
public void startTransaction(BrokerClient client,
java.lang.String transactionId)
throws javax.jms.JMSException
startTransaction in interface BrokerContainerclient - transactionId -
javax.jms.JMSException
public void rollbackTransaction(BrokerClient client,
java.lang.String transactionId)
throws javax.jms.JMSException
rollbackTransaction in interface BrokerContainerclient - transactionId -
javax.jms.JMSException
public void commitTransaction(BrokerClient client,
java.lang.String transactionId)
throws javax.jms.JMSException
commitTransaction in interface BrokerContainerclient - transactionId -
javax.jms.JMSException
public void sendMessage(BrokerClient client,
ActiveMQMessage message)
throws javax.jms.JMSException
sendMessage in interface BrokerContainerclient - message -
javax.jms.JMSExceptionpublic void registerRemoteClientID(java.lang.String remoteClientID)
registerRemoteClientID in interface BrokerContainerremoteClientID - public void deregisterRemoteClientID(java.lang.String remoteClientID)
deregisterRemoteClientID in interface BrokerContainerremoteClientID -
public void acknowledgeMessage(BrokerClient client,
MessageAck ack)
throws javax.jms.JMSException
acknowledgeMessage in interface BrokerContainerclient - ack -
javax.jms.JMSException
public void durableUnsubscribe(BrokerClient client,
DurableUnsubscribe ds)
throws javax.jms.JMSException
durableUnsubscribe in interface BrokerContainerclient - ds -
javax.jms.JMSException
public void startTransaction(BrokerClient client,
ActiveMQXid xid)
throws javax.transaction.xa.XAException
startTransaction in interface BrokerContainerclient - xid -
javax.transaction.xa.XAException
public ActiveMQXid[] getPreparedTransactions(BrokerClient client)
throws javax.transaction.xa.XAException
getPreparedTransactions in interface BrokerContainerclient -
javax.transaction.xa.XAException
public int prepareTransaction(BrokerClient client,
ActiveMQXid xid)
throws javax.transaction.xa.XAException
prepareTransaction in interface BrokerContainerclient - xid -
javax.transaction.xa.XAException
public void rollbackTransaction(BrokerClient client,
ActiveMQXid xid)
throws javax.transaction.xa.XAException
rollbackTransaction in interface BrokerContainerclient - xid -
javax.transaction.xa.XAException
public void commitTransaction(BrokerClient client,
ActiveMQXid xid,
boolean onePhase)
throws javax.transaction.xa.XAException
commitTransaction in interface BrokerContainerclient - xid - onePhase -
javax.transaction.xa.XAExceptionpublic void capacityChanged(CapacityMonitorEvent event)
capacityChanged in interface CapacityMonitorEventListenerevent - public java.util.List getTransportConnectors()
BrokerContainer
getTransportConnectors in interface BrokerContainerpublic void setTransportConnectors(java.util.List transportConnectors)
setTransportConnectors in interface BrokerContainerpublic void addConnector(BrokerConnector connector)
BrokerContainer
addConnector in interface BrokerContainerconnector - public void removeConnector(BrokerConnector connector)
BrokerContainer
removeConnector in interface BrokerContainerconnector -
public void addConnector(java.lang.String bindAddress)
throws javax.jms.JMSException
BrokerContainer
addConnector in interface BrokerContainerjavax.jms.JMSException
public void addConnector(java.lang.String bindAddress,
WireFormat wireFormat)
throws javax.jms.JMSException
BrokerContainer
addConnector in interface BrokerContainerjavax.jms.JMSExceptionpublic void addConnector(TransportServerChannel transportConnector)
BrokerContainer
addConnector in interface BrokerContainerpublic java.util.List getNetworkConnectors()
BrokerContainerNetworkConnector
instances used to communicate with the network of Broker instances
getNetworkConnectors in interface BrokerContainerpublic void setNetworkConnectors(java.util.List networkConnectors)
setNetworkConnectors in interface BrokerContainer
public NetworkConnector addNetworkConnector(java.lang.String uri)
throws javax.jms.JMSException
BrokerContainer
addNetworkConnector in interface BrokerContainerjavax.jms.JMSExceptionpublic NetworkConnector addNetworkConnector()
BrokerContainer
addNetworkConnector in interface BrokerContainerpublic void addNetworkConnector(NetworkConnector connector)
BrokerContainer
addNetworkConnector in interface BrokerContainerpublic void removeNetworkConnector(NetworkConnector connector)
BrokerContainer
removeNetworkConnector in interface BrokerContainerpublic Broker getBroker()
getBroker in interface BrokerContainerpublic PersistenceAdapter getPersistenceAdapter()
BrokerContainer
getPersistenceAdapter in interface BrokerContainerpublic void setPersistenceAdapter(PersistenceAdapter persistenceAdapter)
setPersistenceAdapter in interface BrokerContainerpublic DiscoveryAgent getDiscoveryAgent()
BrokerContainer
getDiscoveryAgent in interface BrokerContainerpublic void setDiscoveryAgent(DiscoveryAgent discoveryAgent)
setDiscoveryAgent in interface BrokerContainerpublic SecurityAdapter getSecurityAdapter()
BrokerContainer
getSecurityAdapter in interface BrokerContainerpublic void setSecurityAdapter(SecurityAdapter securityAdapter)
BrokerContainer
setSecurityAdapter in interface BrokerContainerpublic RedeliveryPolicy getRedeliveryPolicy()
public void setRedeliveryPolicy(RedeliveryPolicy redeliveryPolicy)
protected void checkBrokerSet()
protected java.util.Map createLocalDiscoveryDetails()
protected java.lang.String getLocalBrokerName()
protected java.lang.String getLocalConnectionURL()
protected void addShutdownHook()
protected void containerShutdown()
|
|||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | ||||||||||