Package | Description |
---|---|
org.apache.activemq |
The core JMS client API implementation classes.
|
org.apache.activemq.advisory |
Support for JMS Advisory messages as well as some helper listeners to listen to the clients, producers and consumers available.
|
org.apache.activemq.command |
Command objects used via the Command Pattern to communicate among nodes
|
org.apache.activemq.state |
Modifier and Type | Method and Description |
---|---|
protected ProducerId |
ActiveMQSession.getNextProducerId() |
Modifier and Type | Method and Description |
---|---|
void |
ActiveMQConnection.addProducer(ProducerId producerId,
ActiveMQMessageProducer producer) |
long |
ActiveMQMessageAuditNoSync.getLastSeqId(ProducerId id) |
void |
ActiveMQConnection.removeProducer(ProducerId producerId) |
Constructor and Description |
---|
ActiveMQMessageProducer(ActiveMQSession session,
ProducerId producerId,
ActiveMQDestination destination,
int sendTimeout) |
Modifier and Type | Method and Description |
---|---|
ProducerId |
ProducerEvent.getProducerId() |
Constructor and Description |
---|
ProducerEvent(ProducerEventSource source,
Destination destination,
ProducerId producerId,
int producerCount) |
ProducerStoppedEvent(ProducerEventSource source,
ActiveMQDestination destination,
ProducerId consumerId,
int count) |
Modifier and Type | Field and Description |
---|---|
protected ProducerId |
ProducerInfo.producerId |
protected ProducerId |
Message.producerId |
protected ProducerId |
ProducerAck.producerId |
protected ProducerId |
MessageId.producerId |
Modifier and Type | Method and Description |
---|---|
ProducerId |
ProducerInfo.getProducerId() |
ProducerId |
Message.getProducerId() |
ProducerId |
ProducerAck.getProducerId()
The producer id that this ack message is destined for.
|
ProducerId |
MessageId.getProducerId() |
Modifier and Type | Method and Description |
---|---|
void |
ActiveMQMessage.setJMSMessageID(ProducerId producerId,
long producerSequenceId)
This will create an object of MessageId.
|
void |
ProducerInfo.setProducerId(ProducerId producerId) |
void |
Message.setProducerId(ProducerId producerId) |
void |
ProducerAck.setProducerId(ProducerId producerId) |
void |
MessageId.setProducerId(ProducerId producerId) |
Constructor and Description |
---|
ConnectionId(ProducerId id) |
MessageId(ProducerId producerId,
long producerSequenceId) |
ProducerAck(ProducerId producerId,
int size) |
ProducerId(ProducerId id) |
ProducerInfo(ProducerId producerId) |
SessionId(ProducerId id) |
Modifier and Type | Method and Description |
---|---|
Set<ProducerId> |
SessionState.getProducerIds() |
Map<ProducerId,ProducerState> |
TransactionState.getProducerStates() |
Modifier and Type | Method and Description |
---|---|
ProducerState |
SessionState.getProducerState(ProducerId producerId) |
Response |
ConnectionStateTracker.processRemoveProducer(ProducerId id) |
Response |
CommandVisitorAdapter.processRemoveProducer(ProducerId id) |
Response |
CommandVisitor.processRemoveProducer(ProducerId id) |
ProducerState |
SessionState.removeProducer(ProducerId id) |
Copyright © 2005–2016 FuseSource, Corp.. All rights reserved.