osmq.broker
Class BrokerEngine
java.lang.Object
osmq.broker.BrokerEngine
- All Implemented Interfaces:
- DataRecordGenerator, java.util.EventListener, ExceptionListener, StateEventListener
- public class BrokerEngine
- extends java.lang.Object
- implements ExceptionListener, StateEventListener, DataRecordGenerator
Methods inherited from class java.lang.Object |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
getStatsEngine
public StatsEngine getStatsEngine()
setLoadTopicOnCreate
public void setLoadTopicOnCreate(boolean b)
isLoadTopicsOnCreate
public boolean isLoadTopicsOnCreate()
getLocalAddress
public java.lang.String getLocalAddress()
getPort
public int getPort()
setPort
public void setPort(int port)
getSlaveQueueCount
public long getSlaveQueueCount()
isActive
public boolean isActive()
isPublisherPaused
public boolean isPublisherPaused()
getServiceName
public java.lang.String getServiceName()
setServiceName
public void setServiceName(java.lang.String sn)
setBinarySocketStreams
public void setBinarySocketStreams(boolean binary)
isBinarySocketStreams
public boolean isBinarySocketStreams()
nextElement
public java.lang.Object nextElement()
hasMoreElements
public boolean hasMoreElements()
isOpened
public boolean isOpened()
setStateEventListener
public void setStateEventListener(StateEventListener l)
getStateEventListener
public StateEventListener getStateEventListener()
setPulsarRate
public void setPulsarRate(int secs)
getPulsarRate
public int getPulsarRate()
getStats
public StatsContainer getStats()
getRuntimeClock
public DurationTimer getRuntimeClock()
setSafestore
public void setSafestore(boolean b)
isSafestore
public boolean isSafestore()
setStartupValues
public void setStartupValues(DataRecord startupvalues)
start
public void start()
throws java.lang.Exception
- Throws:
java.lang.Exception
pausePublisherProcessing
public void pausePublisherProcessing(boolean v)
resampleRate
public void resampleRate()
flushNamedQueue
public void flushNamedQueue(java.lang.String name)
dropTopicsFor
public void dropTopicsFor(java.lang.String subscribername)
onException
public void onException(java.lang.Exception e)
- Description copied from interface:
ExceptionListener
- Notify user of an exception.
- Specified by:
onException
in interface ExceptionListener
- Parameters:
e
- the exception.
onEvent
public void onEvent(StateEvent e)
- Specified by:
onEvent
in interface StateEventListener
getDataRecord
public DataRecord getDataRecord()
- Specified by:
getDataRecord
in interface DataRecordGenerator
stop
public void stop()
fullShutDown
public void fullShutDown()
normalShutdown
public void normalShutdown()
shutDown
public void shutDown()
loadConfigFile
public void loadConfigFile(java.lang.String filename)
throws java.lang.Exception
- Throws:
java.lang.Exception