OSMQ
v2.0.1

osmq.broker
Class BrokerEngine

java.lang.Object
  extended byosmq.broker.BrokerEngine
All Implemented Interfaces:
DataRecordGenerator, java.util.EventListener, ExceptionListener, StateEventListener

public class BrokerEngine
extends java.lang.Object
implements ExceptionListener, StateEventListener, DataRecordGenerator


Method Summary
 void dropTopicsFor(java.lang.String subscribername)
           
 void flushNamedQueue(java.lang.String name)
           
 void fullShutDown()
           
 DataRecord getDataRecord()
           
 java.lang.String getLocalAddress()
           
 int getPort()
           
 int getPulsarRate()
           
 DurationTimer getRuntimeClock()
           
 java.lang.String getServiceName()
           
 long getSlaveQueueCount()
           
 StateEventListener getStateEventListener()
           
 StatsContainer getStats()
           
 StatsEngine getStatsEngine()
           
 boolean hasMoreElements()
           
 boolean isActive()
           
 boolean isBinarySocketStreams()
           
 boolean isLoadTopicsOnCreate()
           
 boolean isOpened()
           
 boolean isPublisherPaused()
           
 boolean isSafestore()
           
 void loadConfigFile(java.lang.String filename)
           
 java.lang.Object nextElement()
           
 void normalShutdown()
           
 void onEvent(StateEvent e)
           
 void onException(java.lang.Exception e)
          Notify user of an exception.
 void pausePublisherProcessing(boolean v)
           
 void resampleRate()
           
 void setBinarySocketStreams(boolean binary)
           
 void setLoadTopicOnCreate(boolean b)
           
 void setPort(int port)
           
 void setPulsarRate(int secs)
           
 void setSafestore(boolean b)
           
 void setServiceName(java.lang.String sn)
           
 void setStartupValues(DataRecord startupvalues)
           
 void setStateEventListener(StateEventListener l)
           
 void shutDown()
           
 void start()
           
 void stop()
           
 
Methods inherited from class java.lang.Object
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Method Detail

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

(c) 2000 - 2003 MQue Systems
All Rights Reserved