public class AmqpAnonymousFallbackProducer extends AmqpProducer
connection, presettle, session
closeRequest, closeTimeoutTask
Constructor and Description |
---|
AmqpAnonymousFallbackProducer(AmqpSession session,
JmsProducerInfo info)
Creates the Anonymous Producer object.
|
Modifier and Type | Method and Description |
---|---|
void |
close(AsyncResult request) |
org.apache.qpid.proton.engine.EndpointState |
getLocalState() |
org.apache.qpid.proton.engine.EndpointState |
getRemoteState() |
boolean |
isAnonymous() |
boolean |
send(JmsOutboundMessageDispatch envelope,
AsyncResult request)
Sends the given message
|
getProducerId, isPresettle, setPresettle
closeOrDetachEndpoint, getEndpoint, getParent, getResourceInfo, isAwaitingClose, isClosed, isOpen, processDeliveryUpdates, processFlowUpdates, processRemoteClose, processRemoteDetach, processRemoteOpen, remotelyClosed, resourceClosed
public AmqpAnonymousFallbackProducer(AmqpSession session, JmsProducerInfo info)
session
- the session that owns this producerinfo
- the JmsProducerInfo for this producer.public boolean send(JmsOutboundMessageDispatch envelope, AsyncResult request) throws IOException, javax.jms.JMSException
AmqpProducer
send
in class AmqpProducer
envelope
- The envelope that contains the message and it's targeted destination.request
- The AsyncRequest that will be notified on send success or failure.IOException
- if an error occurs sending the messagejavax.jms.JMSException
- if an error occurs while preparing the message for send.public void close(AsyncResult request)
close
in class AmqpAbstractResource<JmsProducerInfo,org.apache.qpid.proton.engine.Sender>
public boolean isAnonymous()
isAnonymous
in class AmqpProducer
public org.apache.qpid.proton.engine.EndpointState getLocalState()
getLocalState
in class AmqpAbstractResource<JmsProducerInfo,org.apache.qpid.proton.engine.Sender>
public org.apache.qpid.proton.engine.EndpointState getRemoteState()
getRemoteState
in class AmqpAbstractResource<JmsProducerInfo,org.apache.qpid.proton.engine.Sender>
Copyright © 2013–2016 The Apache Software Foundation. All rights reserved.