Docjar: A Java Source and Docuemnt Enginecom.*    java.*    javax.*    org.*    all    new    plug-in

Quick Search    Search Deep
Overview  Package   Class  Use  Deprecated  Index 
Home >> All >> org >> activemq >> [ broker overview ]  PREV CLASS  NEXT CLASS
SUMMARY: JavaDoc of org.activemq.broker.BrokerContainer JAVADOC | Sourc code of org.activemq.broker.BrokerContainer SOURCE | Download org.activemq.broker.BrokerContainer DOWNLOAD | NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD

org.activemq.broker
Interface BrokerContainer  view BrokerContainer download BrokerContainer.java

All Superinterfaces:
org.activemq.service.Service
public interface BrokerContainer
extends org.activemq.service.Service

The ActiveMQ JMS Broker Container which contains a Broker and one or more instances talking over some org.activemq.transport.TransportChannel

Note that once a broker container has been stopped it should be discarded and a new service instance created again. Calling start() on a stopped broker will not usually work.

Version:
$Revision: 1.1.1.1 $

Method Summary
 void acknowledgeMessage(BrokerClient client, org.activemq.message.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, org.activemq.io.WireFormat wireFormat)
          Adds a new transport connector for the given bind address and wire format
 void addConnector(org.activemq.transport.TransportServerChannel transportConnector)
          Adds a new transport connector for the given transportConnector
 org.activemq.transport.NetworkConnector addNetworkConnector()
          Adds a new network connector
 void addNetworkConnector(org.activemq.transport.NetworkConnector connector)
          Adds a new network connector
 org.activemq.transport.NetworkConnector addNetworkConnector(java.lang.String uri)
          Adds a new network connector for the given URI
 void commitTransaction(BrokerClient client, org.activemq.message.ActiveMQXid xid, boolean onePhase)
          Commit an XA transaction.
 void commitTransaction(BrokerClient client, java.lang.String transactionId)
          Commit a transaction
 void deregisterConnection(BrokerClient client, org.activemq.message.ConnectionInfo info)
          un-registers a Connection
 void deregisterMessageConsumer(BrokerClient client, org.activemq.message.ConsumerInfo info)
          De-register a MessageConsumer from the Broker
 void deregisterMessageProducer(BrokerClient client, org.activemq.message.ProducerInfo info)
          De-register a MessageProducer from the Broker
 void deregisterRemoteClientID(java.lang.String remoteClientID)
          deregister a remote clientID
 void deregisterSession(BrokerClient client, org.activemq.message.SessionInfo info)
          De-register a client-side Session from the Broker (used for monitoring)
 void durableUnsubscribe(BrokerClient client, org.activemq.message.DurableUnsubscribe ds)
          Command to delete a durable topic subscription
 Broker getBroker()
           
 org.activemq.transport.DiscoveryAgent getDiscoveryAgent()
          Returns the discovery agent if one is available or null if discovery is not enabled
 java.util.List getNetworkConnectors()
          Returns a list of org.activemq.transport.NetworkConnector instances used to communicate with the network of Broker instances
 org.activemq.store.PersistenceAdapter getPersistenceAdapter()
          Returns the persistence adapter
 org.activemq.message.ActiveMQXid[] getPreparedTransactions(BrokerClient client)
          Gets the prepared XA transactions.
 org.activemq.security.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, org.activemq.message.ActiveMQXid xid)
          Prepare an XA transaction.
 void registerConnection(BrokerClient client, org.activemq.message.ConnectionInfo info)
          registers a new Connection
 void registerMessageConsumer(BrokerClient client, org.activemq.message.ConsumerInfo info)
          Registers a MessageConsumer
 void registerMessageProducer(BrokerClient client, org.activemq.message.ProducerInfo info)
          Registers a MessageProducer
 void registerRemoteClientID(java.lang.String remoteClientID)
          register a remote clientID
 void registerSession(BrokerClient client, org.activemq.message.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(org.activemq.transport.NetworkConnector connector)
          Removes the given network connector
 void rollbackTransaction(BrokerClient client, org.activemq.message.ActiveMQXid xid)
          Rollback an XA transaction.
 void rollbackTransaction(BrokerClient client, java.lang.String transactionId)
          Rollback a transacton
 void sendMessage(BrokerClient client, org.activemq.message.ActiveMQMessage message)
          Send a non-transacted message to the Broker
 void setDiscoveryAgent(org.activemq.transport.DiscoveryAgent discoveryAgent)
           
 void setNetworkConnectors(java.util.List networkConnectors)
           
 void setPersistenceAdapter(org.activemq.store.PersistenceAdapter persistenceAdapter)
           
 void setSecurityAdapter(org.activemq.security.SecurityAdapter securityAdapter)
          Sets the security adapter used to authenticate and authorize access to JMS resources
 void setTransportConnectors(java.util.List transportConnectors)
           
 void startTransaction(BrokerClient client, org.activemq.message.ActiveMQXid xid)
          Start an XA transaction.
 void startTransaction(BrokerClient client, java.lang.String transactionId)
          Start a transaction from the Client session
 
Methods inherited from interface org.activemq.service.Service
start, stop
 

Method Detail

registerConnection

public void registerConnection(BrokerClient client,
                               org.activemq.message.ConnectionInfo info)
                        throws javax.jms.JMSException
registers a new Connection

deregisterConnection

public void deregisterConnection(BrokerClient client,
                                 org.activemq.message.ConnectionInfo info)
                          throws javax.jms.JMSException
un-registers a Connection

registerMessageConsumer

public void registerMessageConsumer(BrokerClient client,
                                    org.activemq.message.ConsumerInfo info)
                             throws javax.jms.JMSException
Registers a MessageConsumer

deregisterMessageConsumer

public void deregisterMessageConsumer(BrokerClient client,
                                      org.activemq.message.ConsumerInfo info)
                               throws javax.jms.JMSException
De-register a MessageConsumer from the Broker

registerMessageProducer

public void registerMessageProducer(BrokerClient client,
                                    org.activemq.message.ProducerInfo info)
                             throws javax.jms.JMSException
Registers a MessageProducer

deregisterMessageProducer

public void deregisterMessageProducer(BrokerClient client,
                                      org.activemq.message.ProducerInfo info)
                               throws javax.jms.JMSException
De-register a MessageProducer from the Broker

registerSession

public void registerSession(BrokerClient client,
                            org.activemq.message.SessionInfo info)
                     throws javax.jms.JMSException
Register a client-side Session (used for Monitoring)

deregisterSession

public void deregisterSession(BrokerClient client,
                              org.activemq.message.SessionInfo info)
                       throws javax.jms.JMSException
De-register a client-side Session from the Broker (used for monitoring)

startTransaction

public void startTransaction(BrokerClient client,
                             java.lang.String transactionId)
                      throws javax.jms.JMSException
Start a transaction from the Client session

rollbackTransaction

public void rollbackTransaction(BrokerClient client,
                                java.lang.String transactionId)
                         throws javax.jms.JMSException
Rollback a transacton

commitTransaction

public void commitTransaction(BrokerClient client,
                              java.lang.String transactionId)
                       throws javax.jms.JMSException
Commit a transaction

sendMessage

public void sendMessage(BrokerClient client,
                        org.activemq.message.ActiveMQMessage message)
                 throws javax.jms.JMSException
Send a non-transacted message to the Broker

acknowledgeMessage

public void acknowledgeMessage(BrokerClient client,
                               org.activemq.message.MessageAck ack)
                        throws javax.jms.JMSException
Acknowledge reciept of a message

durableUnsubscribe

public void durableUnsubscribe(BrokerClient client,
                               org.activemq.message.DurableUnsubscribe ds)
                        throws javax.jms.JMSException
Command to delete a durable topic subscription

startTransaction

public void startTransaction(BrokerClient client,
                             org.activemq.message.ActiveMQXid xid)
                      throws javax.transaction.xa.XAException
Start an XA transaction.

getPreparedTransactions

public org.activemq.message.ActiveMQXid[] getPreparedTransactions(BrokerClient client)
                                                           throws javax.transaction.xa.XAException
Gets the prepared XA transactions.

prepareTransaction

public int prepareTransaction(BrokerClient client,
                              org.activemq.message.ActiveMQXid xid)
                       throws javax.transaction.xa.XAException
Prepare an XA transaction.

rollbackTransaction

public void rollbackTransaction(BrokerClient client,
                                org.activemq.message.ActiveMQXid xid)
                         throws javax.transaction.xa.XAException
Rollback an XA transaction.

commitTransaction

public void commitTransaction(BrokerClient client,
                              org.activemq.message.ActiveMQXid xid,
                              boolean onePhase)
                       throws javax.transaction.xa.XAException
Commit an XA transaction.

addConnector

public void addConnector(BrokerConnector connector)
Called when a new connector is added to this container

removeConnector

public void removeConnector(BrokerConnector connector)
Called when a connector is removed to this container

getBroker

public Broker getBroker()

getTransportConnectors

public java.util.List getTransportConnectors()
Returns the transport connectors used to communicate with clients

setTransportConnectors

public void setTransportConnectors(java.util.List transportConnectors)

getNetworkConnectors

public java.util.List getNetworkConnectors()
Returns a list of org.activemq.transport.NetworkConnector instances used to communicate with the network of Broker instances

setNetworkConnectors

public void setNetworkConnectors(java.util.List networkConnectors)

getPersistenceAdapter

public org.activemq.store.PersistenceAdapter getPersistenceAdapter()
Returns the persistence adapter

setPersistenceAdapter

public void setPersistenceAdapter(org.activemq.store.PersistenceAdapter persistenceAdapter)

getDiscoveryAgent

public org.activemq.transport.DiscoveryAgent getDiscoveryAgent()
Returns the discovery agent if one is available or null if discovery is not enabled

setDiscoveryAgent

public void setDiscoveryAgent(org.activemq.transport.DiscoveryAgent discoveryAgent)

getSecurityAdapter

public org.activemq.security.SecurityAdapter getSecurityAdapter()
Returns the security adapter used to authenticate and authorize access to JMS resources

setSecurityAdapter

public void setSecurityAdapter(org.activemq.security.SecurityAdapter securityAdapter)
Sets the security adapter used to authenticate and authorize access to JMS resources

addNetworkConnector

public org.activemq.transport.NetworkConnector addNetworkConnector(java.lang.String uri)
                                                            throws javax.jms.JMSException
Adds a new network connector for the given URI

addNetworkConnector

public org.activemq.transport.NetworkConnector addNetworkConnector()
Adds a new network connector

addNetworkConnector

public void addNetworkConnector(org.activemq.transport.NetworkConnector connector)
Adds a new network connector

removeNetworkConnector

public void removeNetworkConnector(org.activemq.transport.NetworkConnector connector)
Removes the given network connector

addConnector

public void addConnector(java.lang.String bindAddress)
                  throws javax.jms.JMSException
Adds a new transport connector for the given bind address

addConnector

public void addConnector(java.lang.String bindAddress,
                         org.activemq.io.WireFormat wireFormat)
                  throws javax.jms.JMSException
Adds a new transport connector for the given bind address and wire format

addConnector

public void addConnector(org.activemq.transport.TransportServerChannel transportConnector)
Adds a new transport connector for the given transportConnector

registerRemoteClientID

public void registerRemoteClientID(java.lang.String remoteClientID)
register a remote clientID

deregisterRemoteClientID

public void deregisterRemoteClientID(java.lang.String remoteClientID)
deregister a remote clientID

Overview  Package   Class  Use  Deprecated  Index 
Home >> All >> org >> activemq >> [ broker overview ]  PREV CLASS  NEXT CLASS
SUMMARY: JavaDoc of org.activemq.broker.BrokerContainer JAVADOC | Sourc code of org.activemq.broker.BrokerContainer SOURCE | Download org.activemq.broker.BrokerContainer DOWNLOAD | NESTED | FIELD | CONSTR | METHOD DETAIL: FIELD | CONSTR | METHOD