public class AmqpFixedProducer extends AmqpProducer
connection, session
closeRequest, closeTimeoutTask
Constructor and Description |
---|
AmqpFixedProducer(AmqpSession session,
JmsProducerInfo info) |
AmqpFixedProducer(AmqpSession session,
JmsProducerInfo info,
org.apache.qpid.proton.engine.Sender sender) |
Modifier and Type | Method and Description |
---|---|
void |
close(AsyncResult request) |
long |
getSendTimeout() |
AmqpSession |
getSession() |
boolean |
isAnonymous() |
boolean |
isPresettle() |
void |
processDeliveryUpdates(AmqpProvider provider)
Called when the Proton Engine signals an Delivery related event has been triggered
for the given endpoint.
|
void |
processFlowUpdates(AmqpProvider provider)
Called when the Proton Engine signals an Flow related event has been triggered
for the given endpoint.
|
void |
remotelyClosed(AmqpProvider provider) |
boolean |
send(JmsOutboundMessageDispatch envelope,
AsyncResult request)
Sends the given message
|
void |
setPresettle(boolean presettle)
Sets whether the producer will presettle all messages that it sends.
|
String |
toString() |
getProducerId
closeOrDetachEndpoint, getEndpoint, getLocalState, getParent, getRemoteState, getResourceInfo, isAwaitingClose, isClosed, isOpen, processRemoteClose, processRemoteDetach, processRemoteOpen, resourceClosed
public AmqpFixedProducer(AmqpSession session, JmsProducerInfo info)
public AmqpFixedProducer(AmqpSession session, JmsProducerInfo info, org.apache.qpid.proton.engine.Sender sender)
public void close(AsyncResult request)
close
in class AmqpAbstractResource<JmsProducerInfo,org.apache.qpid.proton.engine.Sender>
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 processFlowUpdates(AmqpProvider provider) throws IOException
AmqpEventSink
processFlowUpdates
in interface AmqpEventSink
processFlowUpdates
in class AmqpAbstractResource<JmsProducerInfo,org.apache.qpid.proton.engine.Sender>
provider
- the AmqpProvider instance for easier access to fire events.IOException
- if an error occurs while processing the update.public void processDeliveryUpdates(AmqpProvider provider) throws IOException
AmqpEventSink
processDeliveryUpdates
in interface AmqpEventSink
processDeliveryUpdates
in class AmqpAbstractResource<JmsProducerInfo,org.apache.qpid.proton.engine.Sender>
provider
- the AmqpProvider instance for easier access to fire events.IOException
- if an error occurs while processing the update.public AmqpSession getSession()
public boolean isAnonymous()
isAnonymous
in class AmqpProducer
public void setPresettle(boolean presettle)
AmqpProducer
setPresettle
in class AmqpProducer
presettle
- true if all messages are sent settled.public boolean isPresettle()
isPresettle
in class AmqpProducer
public long getSendTimeout()
public void remotelyClosed(AmqpProvider provider)
remotelyClosed
in class AmqpAbstractResource<JmsProducerInfo,org.apache.qpid.proton.engine.Sender>
Copyright © 2013–2016 The Apache Software Foundation. All rights reserved.