public class AmqpWireFormatFactory extends Object implements WireFormatFactory
Constructor and Description |
---|
AmqpWireFormatFactory() |
Modifier and Type | Method and Description |
---|---|
WireFormat |
createWireFormat() |
int |
getIdelTimeout() |
int |
getMaxAmqpFrameSize() |
long |
getMaxFrameSize() |
int |
getProducerCredit() |
String |
getTransformer() |
boolean |
isAllowNonSaslConnections() |
void |
setAllowNonSaslConnections(boolean allowNonSaslConnections) |
void |
setIdelTimeout(int idelTimeout) |
void |
setMaxAmqpFrameSize(int maxAmqpFrameSize) |
void |
setMaxFrameSize(long maxFrameSize) |
void |
setProducerCredit(int producerCredit) |
void |
setTransformer(String transformer) |
public AmqpWireFormatFactory()
public WireFormat createWireFormat()
createWireFormat
in interface WireFormatFactory
public int getMaxAmqpFrameSize()
public void setMaxAmqpFrameSize(int maxAmqpFrameSize)
public long getMaxFrameSize()
public void setMaxFrameSize(long maxFrameSize)
public int getIdelTimeout()
public void setIdelTimeout(int idelTimeout)
public int getProducerCredit()
public void setProducerCredit(int producerCredit)
public String getTransformer()
public void setTransformer(String transformer)
public boolean isAllowNonSaslConnections()
public void setAllowNonSaslConnections(boolean allowNonSaslConnections)
Copyright © 2005–2019 The Apache Software Foundation. All rights reserved.