|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.activemq.broker.impl.BrokerConnectorImpl
An implementation of the broker (the JMS server)
Constructor Summary | |
BrokerConnectorImpl(BrokerContainer container,
java.lang.String bindAddress,
WireFormat wireFormat)
Helper constructor for TCP protocol with the given bind address |
|
BrokerConnectorImpl(BrokerContainer container,
TransportServerChannel serverChannel)
|
Method Summary | |
void |
acknowledgeMessage(BrokerClient client,
MessageAck ack)
Acknowledge reciept of a message |
void |
addClient(TransportChannel channel)
Called when a new channel is added to a server |
void |
commitTransaction(BrokerClient client,
ActiveMQXid xid,
boolean onePhase)
Commit an XA transaction. |
void |
commitTransaction(BrokerClient client,
java.lang.String transactionId)
Commit a transaction |
protected static TransportServerChannel |
createTransportServerChannel(WireFormat wireFormat,
java.lang.String bindAddress)
Factory method ot create a transport channel |
void |
deregisterClient(BrokerClient client,
ConnectionInfo info)
Deregister a Broker Client |
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 |
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 |
int |
getBrokerCapacity()
Get a hint about the broker capacity for more messages |
BrokerContainer |
getBrokerContainer()
|
BrokerInfo |
getBrokerInfo()
|
ActiveMQXid[] |
getPreparedTransactions(BrokerClient client)
Gets the prepared XA transactions. |
java.lang.String |
getResourceManagerId(BrokerClient client)
Gets the unique id of the resource manager used for managing xa transactions. |
TransportServerChannel |
getServerChannel()
|
int |
prepareTransaction(BrokerClient client,
ActiveMQXid xid)
Prepare an XA transaction. |
void |
registerClient(BrokerClient client,
ConnectionInfo info)
Register a Broker Client |
void |
registerMessageConsumer(BrokerClient client,
ConsumerInfo info)
Registers a MessageConsumer |
void |
registerMessageProducer(BrokerClient client,
ProducerInfo info)
Registers a MessageProducer |
void |
registerSession(BrokerClient client,
SessionInfo info)
Register a client-side Session (used for Monitoring) |
void |
removeClient(TransportChannel channel)
Called when a channel has been closed and removed from a server |
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 |
start()
start the Broker |
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 Broker |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
public BrokerConnectorImpl(BrokerContainer container, java.lang.String bindAddress, WireFormat wireFormat) throws javax.jms.JMSException
container
- bindAddress
-
javax.jms.JMSException
public BrokerConnectorImpl(BrokerContainer container, TransportServerChannel serverChannel)
container
- serverChannel
- Method Detail |
public BrokerInfo getBrokerInfo()
getBrokerInfo
in interface BrokerConnector
public int getBrokerCapacity()
getBrokerCapacity
in interface BrokerConnector
public TransportServerChannel getServerChannel()
getServerChannel
in interface BrokerConnector
public void start() throws javax.jms.JMSException
start
in interface Service
javax.jms.JMSException
public void stop() throws javax.jms.JMSException
stop
in interface Service
javax.jms.JMSException
public void registerClient(BrokerClient client, ConnectionInfo info) throws javax.jms.JMSException
registerClient
in interface BrokerConnector
client
- info
- contains infomation about the Connection this Client represents
javax.jms.JMSException
javax.jms.InvalidClientIDException
- if the JMS client specifies an invalid or duplicate client ID.
javax.jms.JMSSecurityException
- if client authentication fails due to an invalid user name or password.public void deregisterClient(BrokerClient client, ConnectionInfo info) throws javax.jms.JMSException
deregisterClient
in interface BrokerConnector
client
- info
-
javax.jms.JMSException
- if some internal error occurspublic void registerMessageConsumer(BrokerClient client, ConsumerInfo info) throws javax.jms.JMSException
registerMessageConsumer
in interface BrokerConnector
client
- info
-
javax.jms.JMSException
javax.jms.JMSSecurityException
- if client authentication fails for the Destination the Consumer applies forpublic void deregisterMessageConsumer(BrokerClient client, ConsumerInfo info) throws javax.jms.JMSException
deregisterMessageConsumer
in interface BrokerConnector
client
- info
-
javax.jms.JMSException
public void registerMessageProducer(BrokerClient client, ProducerInfo info) throws javax.jms.JMSException
registerMessageProducer
in interface BrokerConnector
client
- info
-
javax.jms.JMSException
javax.jms.JMSSecurityException
- if client authentication fails for the Destination the Consumer applies forpublic void deregisterMessageProducer(BrokerClient client, ProducerInfo info) throws javax.jms.JMSException
deregisterMessageProducer
in interface BrokerConnector
client
- info
-
javax.jms.JMSException
public void registerSession(BrokerClient client, SessionInfo info) throws javax.jms.JMSException
registerSession
in interface BrokerConnector
client
- info
-
javax.jms.JMSException
public void deregisterSession(BrokerClient client, SessionInfo info) throws javax.jms.JMSException
deregisterSession
in interface BrokerConnector
client
- info
-
javax.jms.JMSException
public void startTransaction(BrokerClient client, java.lang.String transactionId) throws javax.jms.JMSException
startTransaction
in interface BrokerConnector
client
- transactionId
-
javax.jms.JMSException
public void rollbackTransaction(BrokerClient client, java.lang.String transactionId) throws javax.jms.JMSException
rollbackTransaction
in interface BrokerConnector
client
- transactionId
-
javax.jms.JMSException
public void commitTransaction(BrokerClient client, java.lang.String transactionId) throws javax.jms.JMSException
commitTransaction
in interface BrokerConnector
client
- transactionId
-
javax.jms.JMSException
public void sendMessage(BrokerClient client, ActiveMQMessage message) throws javax.jms.JMSException
sendMessage
in interface BrokerConnector
client
- message
-
javax.jms.JMSException
public void acknowledgeMessage(BrokerClient client, MessageAck ack) throws javax.jms.JMSException
acknowledgeMessage
in interface BrokerConnector
client
- ack
-
javax.jms.JMSException
public void durableUnsubscribe(BrokerClient client, DurableUnsubscribe ds) throws javax.jms.JMSException
durableUnsubscribe
in interface BrokerConnector
client
- ds
-
javax.jms.JMSException
public void addClient(TransportChannel channel)
TransportChannelListener
addClient
in interface TransportChannelListener
channel
- - client to addpublic void removeClient(TransportChannel channel)
TransportChannelListener
removeClient
in interface TransportChannelListener
channel
- - client to removepublic BrokerContainer getBrokerContainer()
getBrokerContainer
in interface BrokerConnector
public void startTransaction(BrokerClient client, ActiveMQXid xid) throws javax.transaction.xa.XAException
startTransaction
in interface BrokerConnector
client
- xid
-
javax.transaction.xa.XAException
BrokerConnector.startTransaction(org.activemq.broker.BrokerClient, org.activemq.message.ActiveMQXid)
public ActiveMQXid[] getPreparedTransactions(BrokerClient client) throws javax.transaction.xa.XAException
getPreparedTransactions
in interface BrokerConnector
client
-
javax.transaction.xa.XAException
BrokerConnector.getPreparedTransactions(org.activemq.broker.BrokerClient)
public int prepareTransaction(BrokerClient client, ActiveMQXid xid) throws javax.transaction.xa.XAException
prepareTransaction
in interface BrokerConnector
client
- xid
-
javax.transaction.xa.XAException
BrokerConnector.prepareTransaction(org.activemq.broker.BrokerClient, org.activemq.message.ActiveMQXid)
public void rollbackTransaction(BrokerClient client, ActiveMQXid xid) throws javax.transaction.xa.XAException
rollbackTransaction
in interface BrokerConnector
client
- xid
-
javax.transaction.xa.XAException
BrokerConnector.rollbackTransaction(org.activemq.broker.BrokerClient, org.activemq.message.ActiveMQXid)
public void commitTransaction(BrokerClient client, ActiveMQXid xid, boolean onePhase) throws javax.transaction.xa.XAException
commitTransaction
in interface BrokerConnector
client
- xid
- onePhase
-
javax.transaction.xa.XAException
BrokerConnector.commitTransaction(org.activemq.broker.BrokerClient, org.activemq.message.ActiveMQXid, boolean)
public java.lang.String getResourceManagerId(BrokerClient client)
BrokerConnector
getResourceManagerId
in interface BrokerConnector
client
-
BrokerConnector.getResourceManagerId(org.activemq.broker.BrokerClient)
protected static TransportServerChannel createTransportServerChannel(WireFormat wireFormat, java.lang.String bindAddress) throws javax.jms.JMSException
bindAddress
-
javax.jms.JMSException
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |