|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.apache.qpid.client.Closeable
org.apache.qpid.client.BasicMessageProducer
public abstract class BasicMessageProducer
Nested Class Summary | |
---|---|
(package private) static class |
BasicMessageProducer.PublishMode
|
Field Summary | |
---|---|
protected int |
_channelId
|
protected AMQDestination |
_destination
The Destination used for this consumer, if specified upon creation. |
protected boolean |
_disableTimestamps
If true, messages will not get a timestamp. |
protected org.slf4j.Logger |
_logger
|
protected AMQProtocolHandler |
_protocolHandler
|
protected AMQSession |
_session
The session used to create this producer |
protected String |
_userID
|
protected BasicMessageProducer.PublishMode |
publishMode
|
Fields inherited from class org.apache.qpid.client.Closeable |
---|
_closed, _closing |
Constructor Summary | |
---|---|
protected |
BasicMessageProducer(AMQConnection connection,
AMQDestination destination,
boolean transacted,
int channelId,
AMQSession session,
AMQProtocolHandler protocolHandler,
long producerId,
boolean immediate,
boolean mandatory,
boolean waitUntilSent)
|
Method Summary | |
---|---|
void |
close()
Closes this object. |
(package private) abstract void |
declareDestination(AMQDestination destination)
|
int |
getDeliveryMode()
|
Destination |
getDestination()
|
boolean |
getDisableMessageID()
|
boolean |
getDisableMessageTimestamp()
|
int |
getPriority()
|
AMQSession |
getSession()
|
long |
getTimeToLive()
|
boolean |
isBound(AMQDestination destination)
|
(package private) void |
resubscribe()
|
void |
send(Destination destination,
Message message)
|
void |
send(Destination destination,
Message message,
int deliveryMode,
int priority,
long timeToLive)
|
void |
send(Destination destination,
Message message,
int deliveryMode,
int priority,
long timeToLive,
boolean mandatory)
|
void |
send(Destination destination,
Message message,
int deliveryMode,
int priority,
long timeToLive,
boolean mandatory,
boolean immediate)
|
void |
send(Destination destination,
Message message,
int deliveryMode,
int priority,
long timeToLive,
boolean mandatory,
boolean immediate,
boolean waitUntilSent)
|
void |
send(Message message)
|
void |
send(Message message,
int deliveryMode)
|
void |
send(Message message,
int deliveryMode,
boolean immediate)
|
void |
send(Message message,
int deliveryMode,
int priority,
long timeToLive)
|
protected void |
sendImpl(AMQDestination destination,
Message message,
int deliveryMode,
int priority,
long timeToLive,
boolean mandatory,
boolean immediate)
|
protected void |
sendImpl(AMQDestination destination,
Message origMessage,
int deliveryMode,
int priority,
long timeToLive,
boolean mandatory,
boolean immediate,
boolean wait)
The caller of this method must hold the failover mutex. |
(package private) abstract void |
sendMessage(AMQDestination destination,
Message origMessage,
AbstractJMSMessage message,
UUID messageId,
int deliveryMode,
int priority,
long timeToLive,
boolean mandatory,
boolean immediate,
boolean wait)
|
void |
setDeliveryMode(int i)
|
void |
setDisableMessageID(boolean b)
|
void |
setDisableMessageTimestamp(boolean b)
|
void |
setEncoding(String encoding)
Set the default encoding for messages produced by this producer. |
void |
setMimeType(String mimeType)
Set the default MIME type for messages produced by this producer. |
void |
setPriority(int i)
|
(package private) void |
setPublishMode()
|
void |
setTimeToLive(long l)
|
Methods inherited from class org.apache.qpid.client.Closeable |
---|
checkNotClosed, isClosed, isClosing |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
protected final org.slf4j.Logger _logger
protected boolean _disableTimestamps
protected AMQDestination _destination
protected AMQProtocolHandler _protocolHandler
protected int _channelId
protected AMQSession _session
protected String _userID
protected BasicMessageProducer.PublishMode publishMode
Constructor Detail |
---|
protected BasicMessageProducer(AMQConnection connection, AMQDestination destination, boolean transacted, int channelId, AMQSession session, AMQProtocolHandler protocolHandler, long producerId, boolean immediate, boolean mandatory, boolean waitUntilSent)
Method Detail |
---|
void setPublishMode()
void resubscribe() throws org.apache.qpid.AMQException
org.apache.qpid.AMQException
abstract void declareDestination(AMQDestination destination)
public void setDisableMessageID(boolean b) throws JMSException
setDisableMessageID
in interface MessageProducer
JMSException
public boolean getDisableMessageID() throws JMSException
getDisableMessageID
in interface MessageProducer
JMSException
public void setDisableMessageTimestamp(boolean b) throws JMSException
setDisableMessageTimestamp
in interface MessageProducer
JMSException
public boolean getDisableMessageTimestamp() throws JMSException
getDisableMessageTimestamp
in interface MessageProducer
JMSException
public void setDeliveryMode(int i) throws JMSException
setDeliveryMode
in interface MessageProducer
JMSException
public int getDeliveryMode() throws JMSException
getDeliveryMode
in interface MessageProducer
JMSException
public void setPriority(int i) throws JMSException
setPriority
in interface MessageProducer
JMSException
public int getPriority() throws JMSException
getPriority
in interface MessageProducer
JMSException
public void setTimeToLive(long l) throws JMSException
setTimeToLive
in interface MessageProducer
JMSException
public long getTimeToLive() throws JMSException
getTimeToLive
in interface MessageProducer
JMSException
public Destination getDestination() throws JMSException
getDestination
in interface MessageProducer
JMSException
public void close()
Closeable
close
in interface MessageProducer
close
in class Closeable
public void send(Message message) throws JMSException
send
in interface MessageProducer
JMSException
public void send(Message message, int deliveryMode) throws JMSException
JMSException
public void send(Message message, int deliveryMode, boolean immediate) throws JMSException
JMSException
public void send(Message message, int deliveryMode, int priority, long timeToLive) throws JMSException
send
in interface MessageProducer
JMSException
public void send(Destination destination, Message message) throws JMSException
send
in interface MessageProducer
JMSException
public void send(Destination destination, Message message, int deliveryMode, int priority, long timeToLive) throws JMSException
send
in interface MessageProducer
JMSException
public void send(Destination destination, Message message, int deliveryMode, int priority, long timeToLive, boolean mandatory) throws JMSException
JMSException
public void send(Destination destination, Message message, int deliveryMode, int priority, long timeToLive, boolean mandatory, boolean immediate) throws JMSException
JMSException
public void send(Destination destination, Message message, int deliveryMode, int priority, long timeToLive, boolean mandatory, boolean immediate, boolean waitUntilSent) throws JMSException
JMSException
protected void sendImpl(AMQDestination destination, Message message, int deliveryMode, int priority, long timeToLive, boolean mandatory, boolean immediate) throws JMSException
JMSException
protected void sendImpl(AMQDestination destination, Message origMessage, int deliveryMode, int priority, long timeToLive, boolean mandatory, boolean immediate, boolean wait) throws JMSException
destination
- origMessage
- deliveryMode
- priority
- timeToLive
- mandatory
- immediate
-
JMSException
abstract void sendMessage(AMQDestination destination, Message origMessage, AbstractJMSMessage message, UUID messageId, int deliveryMode, int priority, long timeToLive, boolean mandatory, boolean immediate, boolean wait) throws JMSException
JMSException
public void setMimeType(String mimeType) throws JMSException
MessageProducer
JMSException
public void setEncoding(String encoding) throws JMSException, UnsupportedEncodingException
MessageProducer
encoding
- the encoding as understood by XXXX how do I specify this?? RG
UnsupportedEncodingException
- if the encoding is not understood
JMSException
public AMQSession getSession()
public boolean isBound(AMQDestination destination) throws JMSException
JMSException
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |