Package com.wombat.mama
Class MamaTransport
- java.lang.Object
-
- com.wombat.mama.MamaTransport
-
public class MamaTransport extends java.lang.Object
-
-
Constructor Summary
Constructors Constructor Description MamaTransport()The constructor initialises all member variables and creates the re-usable objects including the transport listeners.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void_create(MamaBridge bridge)void_create(java.lang.String name, MamaBridge bridge)voidaddTransportListener(MamaTransportListener transportListener)This function will set the client listener, note that only one listener or extended listener is supported at any one time.voidaddTransportTopicListener(MamaTransportTopicListener transportTopicListener)This function will set the client topic listener, note that only one topic listener is supported at any one time.voidcreate(MamaBridge bridge)voidcreate(java.lang.String name, MamaBridge bridge)voiddestroy()MamaBridgegetBridge()java.lang.StringgetDescription()booleangetInvokeQualityForAllSubscs()java.lang.StringgetName()doublegetOutboundThrottle()doublegetOutboundThrottle(MamaThrottleInstance throttleInstance)longgetPointerVal()shortgetQuality()voidremoveTransportListener(MamaTransportListener transportListener)This function will remove the current transport listener.voidremoveTransportTopicListener()This function will remove the current topic listener.voidrequestConflation()voidrequestEndConflation()voidsetDescription(java.lang.String description)voidsetInvokeQualityForAllSubscs(boolean invokeQualityForAllSubscs)voidsetName(java.lang.String name)voidsetOutboundThrottle(double outboundThrottle)voidsetOutboundThrottle(MamaThrottleInstance throttleInstance, double outboundThrottle)
-
-
-
Method Detail
-
addTransportListener
public void addTransportListener(MamaTransportListener transportListener)
This function will set the client listener, note that only one listener or extended listener is supported at any one time.
-
addTransportTopicListener
public void addTransportTopicListener(MamaTransportTopicListener transportTopicListener)
This function will set the client topic listener, note that only one topic listener is supported at any one time.
-
removeTransportListener
public void removeTransportListener(MamaTransportListener transportListener)
This function will remove the current transport listener. It will actually remove both the basic and extended listeners.
-
removeTransportTopicListener
public void removeTransportTopicListener()
This function will remove the current topic listener.
-
getPointerVal
public long getPointerVal()
-
create
public void create(MamaBridge bridge)
-
_create
public void _create(MamaBridge bridge)
-
create
public void create(java.lang.String name, MamaBridge bridge)
-
_create
public void _create(java.lang.String name, MamaBridge bridge)
-
destroy
public void destroy()
-
getOutboundThrottle
public double getOutboundThrottle(MamaThrottleInstance throttleInstance)
-
getOutboundThrottle
public double getOutboundThrottle()
-
setOutboundThrottle
public void setOutboundThrottle(MamaThrottleInstance throttleInstance, double outboundThrottle)
-
setOutboundThrottle
public void setOutboundThrottle(double outboundThrottle)
-
setDescription
public void setDescription(java.lang.String description)
-
getDescription
public java.lang.String getDescription()
-
setInvokeQualityForAllSubscs
public void setInvokeQualityForAllSubscs(boolean invokeQualityForAllSubscs)
-
getInvokeQualityForAllSubscs
public boolean getInvokeQualityForAllSubscs()
-
getQuality
public short getQuality()
-
getBridge
public MamaBridge getBridge()
-
requestConflation
public void requestConflation()
-
requestEndConflation
public void requestEndConflation()
-
getName
public java.lang.String getName()
-
setName
public void setName(java.lang.String name)
-
-