|
|||||||||
| Home >> All >> org >> activemq >> [ broker overview ] | PREV NEXT | ||||||||
A
- acknowledgeMessage(BrokerClient, MessageAck) - Method in interface org.activemq.broker.Broker
- Acknowledge positively or negatively, the consumption of a message by the Message Consumer
- acknowledgeMessage(BrokerClient, MessageAck) - Method in interface org.activemq.broker.BrokerConnector
- Acknowledge reciept of a message
- acknowledgeMessage(BrokerClient, MessageAck) - Method in interface org.activemq.broker.BrokerContainer
- Acknowledge reciept of a message
- addClient(BrokerClient, ConnectionInfo) - Method in interface org.activemq.broker.Broker
- Notification of a new client attempting to connect, which can be rejected if authentication or authorization fails.
- addConnector(BrokerConnector) - Method in interface org.activemq.broker.BrokerContainer
- Called when a new connector is added to this container
- addConnector(String) - Method in interface org.activemq.broker.BrokerContainer
- Adds a new transport connector for the given bind address
- addConnector(String, WireFormat) - Method in interface org.activemq.broker.BrokerContainer
- Adds a new transport connector for the given bind address and wire format
- addConnector(TransportServerChannel) - Method in interface org.activemq.broker.BrokerContainer
- Adds a new transport connector for the given transportConnector
- addConsumerInfoListener(ConsumerInfoListener) - Method in interface org.activemq.broker.Broker
- Add a ConsumerInfoListener to the Broker
- addMessageConsumer(BrokerClient, ConsumerInfo) - Method in interface org.activemq.broker.Broker
- Add an active message consumer, which could be rejected due to authorization
- addMessageProducer(BrokerClient, ProducerInfo) - Method in interface org.activemq.broker.Broker
- Adds a new message producer, which could be rejected due to authorization
- addNetworkConnector(String) - Method in interface org.activemq.broker.BrokerContainer
- Adds a new network connector for the given URI
- addNetworkConnector() - Method in interface org.activemq.broker.BrokerContainer
- Adds a new network connector
- addNetworkConnector(NetworkConnector) - Method in interface org.activemq.broker.BrokerContainer
- Adds a new network connector
B
- Broker - interface org.activemq.broker.Broker.
- The Message Broker which routes messages, maintains subscriptions and connections, acknowlegdges messages and handles transactions.
- BrokerAdmin - interface org.activemq.broker.BrokerAdmin.
- Provides a admin view to a broker.
- BrokerAdminTest - class org.activemq.broker.BrokerAdminTest.
- BrokerAdminTest() - Constructor for class org.activemq.broker.BrokerAdminTest
- BrokerClient - interface org.activemq.broker.BrokerClient.
- A Broker side proxy representing mostly outbound JMS Connnection
- BrokerClientStub - class org.activemq.broker.BrokerClientStub.
- A mock dispatcher for testing
- BrokerClientStub() - Constructor for class org.activemq.broker.BrokerClientStub
- BrokerClientStub(Object) - Constructor for class org.activemq.broker.BrokerClientStub
- BrokerConnector - interface org.activemq.broker.BrokerConnector.
- The Broker is the client side interface to the JMS server
- BrokerContainer - interface org.activemq.broker.BrokerContainer.
- 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.
- BrokerContainerFactory - interface org.activemq.broker.BrokerContainerFactory.
- A Factory of BrokerContainer objects
- BrokerContext - class org.activemq.broker.BrokerContext.
- A cache of all the brokers and broker connectors in use which is usually used in a singleton way but could be used in an IoC style manner.
- BrokerContext() - Constructor for class org.activemq.broker.BrokerContext
- brokersByName - Variable in class org.activemq.broker.BrokerContext
C
- ConsumerInfoListener - interface org.activemq.broker.ConsumerInfoListener.
- A listener for ConsumerInfo packets
- cleanUp() - Method in interface org.activemq.broker.BrokerClient
- Called when the transport has been terminated, so do our best to shut down any resources and deregister from any subscriptions etc
- cleanUp() - Method in class org.activemq.broker.BrokerClientStub
- commitTransaction(BrokerClient, String) - Method in interface org.activemq.broker.Broker
- commit a transaction
- commitTransaction(BrokerClient, ActiveMQXid, boolean) - Method in interface org.activemq.broker.Broker
- commitTransaction(BrokerClient, String) - Method in interface org.activemq.broker.BrokerConnector
- Commit a transaction
- commitTransaction(BrokerClient, ActiveMQXid, boolean) - Method in interface org.activemq.broker.BrokerConnector
- Commit an XA transaction.
- commitTransaction(BrokerClient, String) - Method in interface org.activemq.broker.BrokerContainer
- Commit a transaction
- commitTransaction(BrokerClient, ActiveMQXid, boolean) - Method in interface org.activemq.broker.BrokerContainer
- Commit an XA transaction.
- connectionInfo - Variable in class org.activemq.broker.BrokerClientStub
- connectorsByURL - Variable in class org.activemq.broker.BrokerContext
- container - Variable in class org.activemq.broker.BrokerAdminTest
- createBrokerContainer(String, BrokerContext) - Method in interface org.activemq.broker.BrokerContainerFactory
- Creates a broker container with the given name
- createMessageContainer(ActiveMQDestination) - Method in interface org.activemq.broker.BrokerAdmin
D
- deleteSubscription(String, String) - Method in interface org.activemq.broker.Broker
- Delete a durable subscriber
- deregisterClient(BrokerClient, ConnectionInfo) - Method in interface org.activemq.broker.BrokerConnector
- Deregister a Broker Client
- deregisterConnection(BrokerClient, ConnectionInfo) - Method in interface org.activemq.broker.BrokerContainer
- un-registers a Connection
- deregisterConnector(String) - Method in class org.activemq.broker.BrokerContext
- deregisterContainer(String, BrokerContainer) - Method in class org.activemq.broker.BrokerContext
- deregisterMessageConsumer(BrokerClient, ConsumerInfo) - Method in interface org.activemq.broker.BrokerConnector
- De-register a MessageConsumer from the Broker
- deregisterMessageConsumer(BrokerClient, ConsumerInfo) - Method in interface org.activemq.broker.BrokerContainer
- De-register a MessageConsumer from the Broker
- deregisterMessageProducer(BrokerClient, ProducerInfo) - Method in interface org.activemq.broker.BrokerConnector
- De-register a MessageProducer from the Broker
- deregisterMessageProducer(BrokerClient, ProducerInfo) - Method in interface org.activemq.broker.BrokerContainer
- De-register a MessageProducer from the Broker
- deregisterRemoteClientID(String) - Method in interface org.activemq.broker.BrokerContainer
- deregister a remote clientID
- deregisterSession(BrokerClient, SessionInfo) - Method in interface org.activemq.broker.BrokerConnector
- De-register a client-side Session from the Broker (used for monitoring)
- deregisterSession(BrokerClient, SessionInfo) - Method in interface org.activemq.broker.BrokerContainer
- De-register a client-side Session from the Broker (used for monitoring)
- destoryMessageContainer(ActiveMQDestination) - Method in interface org.activemq.broker.BrokerAdmin
- dispatch(ActiveMQMessage) - Method in interface org.activemq.broker.BrokerClient
- Dispatch an ActiveMQMessage to the end client
- dispatch(ActiveMQMessage) - Method in class org.activemq.broker.BrokerClientStub
- durableUnsubscribe(BrokerClient, DurableUnsubscribe) - Method in interface org.activemq.broker.BrokerConnector
- Command to delete a durable topic subscription
- durableUnsubscribe(BrokerClient, DurableUnsubscribe) - Method in interface org.activemq.broker.BrokerContainer
- Command to delete a durable topic subscription
F
- flushMessages() - Method in class org.activemq.broker.BrokerClientStub
G
- getBroker() - Method in interface org.activemq.broker.BrokerContainer
- getBrokerAdmin() - Method in interface org.activemq.broker.Broker
- Get's the admin interface of the broker.
- getBrokerAdmin() - Method in class org.activemq.broker.BrokerAdminTest
- getBrokerCapacity() - Method in interface org.activemq.broker.BrokerConnector
- Get a hint about the broker capacity for more messages
- getBrokerClusterName() - Method in interface org.activemq.broker.Broker
- getBrokerConnector() - Method in interface org.activemq.broker.BrokerClient
- getBrokerConnector() - Method in class org.activemq.broker.BrokerClientStub
- getBrokerContainer() - Method in interface org.activemq.broker.BrokerConnector
- getBrokerContainerByName(String, String, BrokerContainerFactory) - Method in class org.activemq.broker.BrokerContext
- getBrokerInfo() - Method in interface org.activemq.broker.Broker
- getBrokerInfo() - Method in interface org.activemq.broker.BrokerConnector
- getBrokerName() - Method in interface org.activemq.broker.Broker
- getCapacity() - Method in interface org.activemq.broker.BrokerClient
- Get the Capacity for in-progress messages at the peer (probably a JMSConnection) Legimate values between 0-100.
- getCapacity() - Method in class org.activemq.broker.BrokerClientStub
- Get the Capacity for in-progress messages at the peer (probably a JMSConnection) Legimate values between 0-100.
- getChannel() - Method in interface org.activemq.broker.BrokerClient
- getChannel() - Method in class org.activemq.broker.BrokerClientStub
- getClientID() - Method in interface org.activemq.broker.BrokerClient
- getClientID() - Method in class org.activemq.broker.BrokerClientStub
- getConnectionInfo() - Method in interface org.activemq.broker.BrokerClient
- getConnectionInfo() - Method in class org.activemq.broker.BrokerClientStub
- getConnectorByURL(String) - Method in class org.activemq.broker.BrokerContext
- getContainerManagerMap() - Method in interface org.activemq.broker.Broker
- getDeadLetterPolicy() - Method in interface org.activemq.broker.Broker
- getDestinationContext(Hashtable) - Method in interface org.activemq.broker.Broker
- Returns the naming context of the destinations available in this broker
- getDiscoveryAgent() - Method in interface org.activemq.broker.BrokerContainer
- Returns the discovery agent if one is available or null if discovery is not enabled
- getInstance() - Static method in class org.activemq.broker.BrokerContext
- getMessageContainerAdmin(ActiveMQDestination) - Method in interface org.activemq.broker.BrokerAdmin
- getNetworkConnectors() - Method in interface org.activemq.broker.BrokerContainer
- Returns a list of org.activemq.transport.NetworkConnector instances used to communicate with the network of Broker instances
- getPersistenceAdapter() - Method in interface org.activemq.broker.Broker
- getPersistenceAdapter() - Method in interface org.activemq.broker.BrokerContainer
- Returns the persistence adapter
- getPersistentQueueContainerManager() - Method in interface org.activemq.broker.Broker
- getPersistentTopicContainerManager() - Method in interface org.activemq.broker.Broker
- getPreparedTransactions(BrokerClient) - Method in interface org.activemq.broker.Broker
- gets a list of all the prepared xa transactions.
- getPreparedTransactions(BrokerClient) - Method in interface org.activemq.broker.BrokerConnector
- Get all the Xids of the prepared XA transactions.
- getPreparedTransactions(BrokerClient) - Method in interface org.activemq.broker.BrokerContainer
- Gets the prepared XA transactions.
- getRedeliveryPolicy() - Method in interface org.activemq.broker.Broker
- getResourceManagerId(BrokerClient) - Method in interface org.activemq.broker.BrokerConnector
- Gets the unique id of the resource manager used for managing xa transactions.
- getSecurityAdapter() - Method in interface org.activemq.broker.Broker
- Returns the security adapter used to authenticate and authorize access to JMS resources
- getSecurityAdapter() - Method in interface org.activemq.broker.BrokerContainer
- Returns the security adapter used to authenticate and authorize access to JMS resources
- getServerChannel() - Method in interface org.activemq.broker.BrokerConnector
- getSubject() - Method in interface org.activemq.broker.BrokerClient
- getSubject() - Method in class org.activemq.broker.BrokerClientStub
- getTempDir() - Method in interface org.activemq.broker.Broker
- Get a temp directory - used for spooling
- getTransientQueueContainerManager() - Method in interface org.activemq.broker.Broker
- getTransientTopicContainerManager() - Method in interface org.activemq.broker.Broker
- getTransportConnectors() - Method in interface org.activemq.broker.BrokerContainer
- Returns the transport connectors used to communicate with clients
I
- initialize(BrokerConnector, TransportChannel) - Method in interface org.activemq.broker.BrokerClient
- Initialize the Brokerclient
- initialize(BrokerConnector, TransportChannel) - Method in class org.activemq.broker.BrokerClientStub
- isBrokerConnection() - Method in interface org.activemq.broker.BrokerClient
- isBrokerConnection() - Method in class org.activemq.broker.BrokerClientStub
- isClusteredConnection() - Method in interface org.activemq.broker.BrokerClient
- isClusteredConnection() - Method in class org.activemq.broker.BrokerClientStub
- isSlowConsumer() - Method in interface org.activemq.broker.BrokerClient
- Get an indication if the peer should be considered as a slow consumer
- isSlowConsumer() - Method in class org.activemq.broker.BrokerClientStub
- Get an indication if the peer should be considered as a slow consumer
L
- listMessageContainerAdmin() - Method in interface org.activemq.broker.BrokerAdmin
M
- messages - Variable in class org.activemq.broker.BrokerClientStub
O
- onConsumerInfo(BrokerClient, ConsumerInfo) - Method in interface org.activemq.broker.ConsumerInfoListener
- ConsumerInfo packet fired from within the broker
- org.activemq.broker - package org.activemq.broker
P
- prepareTransaction(BrokerClient, ActiveMQXid) - Method in interface org.activemq.broker.Broker
- prepareTransaction(BrokerClient, ActiveMQXid) - Method in interface org.activemq.broker.BrokerConnector
- Prepare an XA transaction.
- prepareTransaction(BrokerClient, ActiveMQXid) - Method in interface org.activemq.broker.BrokerContainer
- Prepare an XA transaction.
R
- registerClient(BrokerClient, ConnectionInfo) - Method in interface org.activemq.broker.BrokerConnector
- Register a Broker Client
- registerConnection(BrokerClient, ConnectionInfo) - Method in interface org.activemq.broker.BrokerContainer
- registers a new Connection
- registerConnector(String, BrokerConnector) - Method in class org.activemq.broker.BrokerContext
- registerContainer(String, BrokerContainer) - Method in class org.activemq.broker.BrokerContext
- registerMessageConsumer(BrokerClient, ConsumerInfo) - Method in interface org.activemq.broker.BrokerConnector
- Registers a MessageConsumer
- registerMessageConsumer(BrokerClient, ConsumerInfo) - Method in interface org.activemq.broker.BrokerContainer
- Registers a MessageConsumer
- registerMessageProducer(BrokerClient, ProducerInfo) - Method in interface org.activemq.broker.BrokerConnector
- Registers a MessageProducer
- registerMessageProducer(BrokerClient, ProducerInfo) - Method in interface org.activemq.broker.BrokerContainer
- Registers a MessageProducer
- registerRemoteClientID(String) - Method in interface org.activemq.broker.BrokerContainer
- register a remote clientID
- registerSession(BrokerClient, SessionInfo) - Method in interface org.activemq.broker.BrokerConnector
- Register a client-side Session (used for Monitoring)
- registerSession(BrokerClient, SessionInfo) - Method in interface org.activemq.broker.BrokerContainer
- Register a client-side Session (used for Monitoring)
- removeClient(BrokerClient, ConnectionInfo) - Method in interface org.activemq.broker.Broker
- A hint to the broker that an BrokerClient has stopped This enables the broker to clean-up any outstanding processing that may be outstanding
- removeConnector(BrokerConnector) - Method in interface org.activemq.broker.BrokerContainer
- Called when a connector is removed to this container
- removeConsumerInfoListener(ConsumerInfoListener) - Method in interface org.activemq.broker.Broker
- Remove a ConsumerInfoListener from the Broker
- removeMessageConsumer(BrokerClient, ConsumerInfo) - Method in interface org.activemq.broker.Broker
- remove an active message consumer
- removeMessageProducer(BrokerClient, ProducerInfo) - Method in interface org.activemq.broker.Broker
- Removes a producer
- removeNetworkConnector(NetworkConnector) - Method in interface org.activemq.broker.BrokerContainer
- Removes the given network connector
- rollbackTransaction(BrokerClient, String) - Method in interface org.activemq.broker.Broker
- rollback a transaction
- rollbackTransaction(BrokerClient, ActiveMQXid) - Method in interface org.activemq.broker.Broker
- rollbackTransaction(BrokerClient, String) - Method in interface org.activemq.broker.BrokerConnector
- Rollback a transacton
- rollbackTransaction(BrokerClient, ActiveMQXid) - Method in interface org.activemq.broker.BrokerConnector
- Rollback an XA transaction.
- rollbackTransaction(BrokerClient, String) - Method in interface org.activemq.broker.BrokerContainer
- Rollback a transacton
- rollbackTransaction(BrokerClient, ActiveMQXid) - Method in interface org.activemq.broker.BrokerContainer
- Rollback an XA transaction.
S
- semaphore - Variable in class org.activemq.broker.BrokerClientStub
- sendMessage(BrokerClient, ActiveMQMessage) - Method in interface org.activemq.broker.Broker
- send a message to the broker
- sendMessage(BrokerClient, ActiveMQMessage) - Method in interface org.activemq.broker.BrokerConnector
- Send a non-transacted message to the Broker
- sendMessage(BrokerClient, ActiveMQMessage) - Method in interface org.activemq.broker.BrokerContainer
- Send a non-transacted message to the Broker
- sendToDeadLetterQueue(String, ActiveMQMessage) - Method in interface org.activemq.broker.Broker
- Add a message to a dead letter queue
- setConnectionInfo(ConnectionInfo) - Method in class org.activemq.broker.BrokerClientStub
- setDeadLetterPolicy(DeadLetterPolicy) - Method in interface org.activemq.broker.Broker
- set the dead letter policy
- setDiscoveryAgent(DiscoveryAgent) - Method in interface org.activemq.broker.BrokerContainer
- setNetworkConnectors(List) - Method in interface org.activemq.broker.BrokerContainer
- setPersistenceAdapter(PersistenceAdapter) - Method in interface org.activemq.broker.Broker
- set the persistence adaptor
- setPersistenceAdapter(PersistenceAdapter) - Method in interface org.activemq.broker.BrokerContainer
- setRedeliveryPolicy(RedeliveryPolicy) - Method in interface org.activemq.broker.Broker
- set the redelivery policy
- setSecurityAdapter(SecurityAdapter) - Method in interface org.activemq.broker.Broker
- Sets the security adapter used to authenticate and authorize access to JMS resources
- setSecurityAdapter(SecurityAdapter) - Method in interface org.activemq.broker.BrokerContainer
- Sets the security adapter used to authenticate and authorize access to JMS resources
- setSubject(Subject) - Method in interface org.activemq.broker.BrokerClient
- Associcates a subject with BrokerClient.
- setSubject(Subject) - Method in class org.activemq.broker.BrokerClientStub
- setTransportConnectors(List) - Method in interface org.activemq.broker.BrokerContainer
- setUp() - Method in class org.activemq.broker.BrokerAdminTest
- singleton - Static variable in class org.activemq.broker.BrokerContext
- start() - Method in class org.activemq.broker.BrokerClientStub
- startTransaction(BrokerClient, String) - Method in interface org.activemq.broker.Broker
- start a transaction
- startTransaction(BrokerClient, ActiveMQXid) - Method in interface org.activemq.broker.Broker
- startTransaction(BrokerClient, String) - Method in interface org.activemq.broker.BrokerConnector
- Start a transaction from the Client session
- startTransaction(BrokerClient, ActiveMQXid) - Method in interface org.activemq.broker.BrokerConnector
- Start an XA transaction
- startTransaction(BrokerClient, String) - Method in interface org.activemq.broker.BrokerContainer
- Start a transaction from the Client session
- startTransaction(BrokerClient, ActiveMQXid) - Method in interface org.activemq.broker.BrokerContainer
- Start an XA transaction.
- stop() - Method in class org.activemq.broker.BrokerClientStub
- subject - Variable in class org.activemq.broker.BrokerClientStub
T
- TEST_QUEUE_NAME - Static variable in class org.activemq.broker.BrokerAdminTest
- tearDown() - Method in class org.activemq.broker.BrokerAdminTest
- testCreateQueue() - Method in class org.activemq.broker.BrokerAdminTest
- testDeleteQueue() - Method in class org.activemq.broker.BrokerAdminTest
- testInitialState() - Method in class org.activemq.broker.BrokerAdminTest
U
- URL - Static variable in class org.activemq.broker.BrokerAdminTest
- updateBrokerCapacity(int) - Method in interface org.activemq.broker.BrokerClient
- Update the peer Connection about the Broker's capacity for messages
- updateBrokerCapacity(int) - Method in class org.activemq.broker.BrokerClientStub
- Update the peer Connection about the Broker's capacity for messages
V
- validateConnection(int) - Method in interface org.activemq.broker.BrokerClient
- Tests the connection to assert that it in fact is alive by asserting that a full round-trip to the client is possible.
- validateConnection(int) - Method in class org.activemq.broker.BrokerClientStub
W
- waitForMessageToArrive() - Method in class org.activemq.broker.BrokerClientStub
A B C D F G I L M O P R S T U V W
|
|||||||||
| Home >> All >> org >> activemq >> [ broker overview ] | PREV NEXT | ||||||||