com.reuters.msgtest
Class RvListen

java.lang.Object
  com.reuters.msgtest.RvListen

All Implemented Interfaces:

com.tibco.tibrv.TibrvMsgCallback

public class RvListen

extends java.lang.Object

implements com.tibco.tibrv.TibrvMsgCallback

Field Summary

static java.lang.String	MESSAGE_LOG_NAME
static java.lang.String	RVLISTEN_LOG_NAME

Constructor Summary

RvListen(java.lang.String[] args)

Method Summary

static org.apache.commons.cli.Option	buildOption(java.lang.String optionName, boolean required, boolean hasArgument, java.lang.String description)
org.apache.commons.cli.Options	buildOptions()
boolean	isExcluded(java.lang.String specificSubject)
static void	main(java.lang.String[] args)
void	onMsg(com.tibco.tibrv.TibrvListener listener, com.tibco.tibrv.TibrvMsg msg)
void	usage(org.apache.commons.cli.Options options)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

RVLISTEN_LOG_NAME

public static java.lang.String RVLISTEN_LOG_NAME

MESSAGE_LOG_NAME

public static java.lang.String MESSAGE_LOG_NAME

Constructor Detail

RvListen

public RvListen(java.lang.String[] args)
         throws java.lang.InterruptedException,
                com.tibco.tibrv.TibrvException

Method Detail

onMsg

public void onMsg(com.tibco.tibrv.TibrvListener listener,
                  com.tibco.tibrv.TibrvMsg msg)

Specified by:

onMsg in interface com.tibco.tibrv.TibrvMsgCallback

isExcluded

public boolean isExcluded(java.lang.String specificSubject)

usage

public void usage(org.apache.commons.cli.Options options)

buildOptions

public org.apache.commons.cli.Options buildOptions()

buildOption

public static org.apache.commons.cli.Option buildOption(java.lang.String optionName,
                                                        boolean required,
                                                        boolean hasArgument,
                                                        java.lang.String description)

Parameters:

optionName -

required -

hasArgument -

description -

Returns:

main

public static void main(java.lang.String[] args)