public class AmqpWireFormat extends Object implements org.apache.activemq.wireformat.WireFormat
Modifier and Type | Class and Description |
---|---|
static interface |
AmqpWireFormat.ResetListener |
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_CONNECTION_TIMEOUT |
static int |
DEFAULT_IDLE_TIMEOUT |
static long |
DEFAULT_MAX_FRAME_SIZE |
static int |
DEFAULT_PRODUCER_CREDIT |
static int |
NO_AMQP_MAX_FRAME_SIZE |
Constructor and Description |
---|
AmqpWireFormat() |
Modifier and Type | Method and Description |
---|---|
int |
getConnectAttemptTimeout() |
int |
getIdleTimeout() |
int |
getMaxAmqpFrameSize() |
long |
getMaxFrameSize() |
AmqpHeader |
getMinimallySupportedHeader()
Returns an AMQP Header object that represents the minimally protocol
versions supported by this transport.
|
int |
getProducerCredit() |
String |
getTransformer() |
int |
getVersion() |
boolean |
isAllowNonSaslConnections() |
boolean |
isHeaderValid(AmqpHeader header)
Given an AMQP header validate that the AMQP magic is present and
if so that the version and protocol values align with what we support.
|
boolean |
isMagicRead() |
ByteSequence |
marshal(Object command) |
void |
marshal(Object command,
DataOutput dataOut) |
void |
resetMagicRead() |
void |
setAllowNonSaslConnections(boolean allowNonSaslConnections) |
void |
setConnectAttemptTimeout(int connectAttemptTimeout) |
void |
setIdleTimeout(int idelTimeout) |
void |
setMaxAmqpFrameSize(int maxAmqpFrameSize) |
void |
setMaxFrameSize(long maxFrameSize) |
void |
setProducerCredit(int producerCredit) |
void |
setProtocolResetListener(AmqpWireFormat.ResetListener listener) |
void |
setTransformer(String transformer) |
void |
setVersion(int version) |
Object |
unmarshal(ByteSequence packet) |
Object |
unmarshal(DataInput dataIn) |
public static final long DEFAULT_MAX_FRAME_SIZE
public static final int NO_AMQP_MAX_FRAME_SIZE
public static final int DEFAULT_CONNECTION_TIMEOUT
public static final int DEFAULT_IDLE_TIMEOUT
public static final int DEFAULT_PRODUCER_CREDIT
public AmqpWireFormat()
public ByteSequence marshal(Object command) throws IOException
marshal
in interface org.apache.activemq.wireformat.WireFormat
IOException
public Object unmarshal(ByteSequence packet) throws IOException
unmarshal
in interface org.apache.activemq.wireformat.WireFormat
IOException
public void marshal(Object command, DataOutput dataOut) throws IOException
marshal
in interface org.apache.activemq.wireformat.WireFormat
IOException
public Object unmarshal(DataInput dataIn) throws IOException
unmarshal
in interface org.apache.activemq.wireformat.WireFormat
IOException
public boolean isHeaderValid(AmqpHeader header)
header
- the header instance received from the client.public AmqpHeader getMinimallySupportedHeader()
public void setVersion(int version)
setVersion
in interface org.apache.activemq.wireformat.WireFormat
public int getVersion()
getVersion
in interface org.apache.activemq.wireformat.WireFormat
public void resetMagicRead()
public void setProtocolResetListener(AmqpWireFormat.ResetListener listener)
public boolean isMagicRead()
public long getMaxFrameSize()
public void setMaxFrameSize(long maxFrameSize)
public int getMaxAmqpFrameSize()
public void setMaxAmqpFrameSize(int maxAmqpFrameSize)
public boolean isAllowNonSaslConnections()
public void setAllowNonSaslConnections(boolean allowNonSaslConnections)
public int getConnectAttemptTimeout()
public void setConnectAttemptTimeout(int connectAttemptTimeout)
public void setProducerCredit(int producerCredit)
public int getProducerCredit()
public String getTransformer()
public void setTransformer(String transformer)
public int getIdleTimeout()
public void setIdleTimeout(int idelTimeout)
Copyright © 2005–2019 FuseSource, Corp.. All rights reserved.