com.aspc.Admin.CountJMSMsg

Class CountMessagesClient

java.lang.Object

com.aspc.remote.jms.Client

com.aspc.Admin.CountJMSMsg.CountMessagesClient

All Implemented Interfaces:

ShutdownListener

public class CountMessagesClient
extends Client

THREAD MODE: SINGLE-THREADED

Since:

Oct 27, 2008

Author:

Lei Gao

Field Summary

Fields inherited from class com.aspc.remote.jms.Client

ATTRIBUTE_RECORD_COUNT, ATTRIBUTE_SENT_MS, ATTRIBUTE_TRANS_MS, ATTRIBUTE_TRANS_NR, DISABLE_JMS, ENV_JMS_MAX_LIVE_MS, ENV_JMS_PENDING_COUNT, ENV_JMS_TIMEOUT, JMS_TIMEOUT, MAX_INACTIVITY_DURATION, PROPERTY_MAX_INACTIVITY_DURATION

Constructor Summary

Constructors

Constructor and Description
CountMessagesClient()

Method Summary

Modifier and Type	Method and Description
java.lang.String	getContextFactory() The context factory to use
protected MessageListener	getMessageListener() The message listener
java.lang.String	getProviderUrl() get the provider URL to use.
void	onMessage(Message message)
void	processMessage(java.lang.String text) Each XML to process.
void	setDirectory(java.lang.String directory)
void	setPeriod(long period)
void	setRequiredJmsContext(java.lang.String requiredJmsContext)
void	setRequiredJmsProviderURL(java.lang.String requiredJmsProviderURL)

Methods inherited from class com.aspc.remote.jms.Client

connect, connectionFailed, getConnectionCount, getConnectionStats, getCurrentClientID, getLastConnected, getTotalSentCount, isConnected, isEnabled, logSentMessage, onException, postPublish, prePublish, reconnectedJMS, refreshContext, send, shutdown, shutdownJMS

Methods inherited from class java.lang.Object

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

Constructor Detail

CountMessagesClient

public CountMessagesClient()

Method Detail

onMessage

public void onMessage(Message message)

Parameters:

message - the message

processMessage

public void processMessage(java.lang.String text)
                    throws java.lang.Exception

Each XML to process.

Parameters:

text - The message text

Throws:

java.lang.Exception - A serious problem

getContextFactory

public java.lang.String getContextFactory()

The context factory to use

Specified by:

getContextFactory in class Client

Returns:

The context factory

getProviderUrl

public java.lang.String getProviderUrl()

get the provider URL to use.

Specified by:

getProviderUrl in class Client

Returns:

the provider URL.

setPeriod

public void setPeriod(long period)

Parameters:

period -

setDirectory

public void setDirectory(java.lang.String directory)

Parameters:

directory - the directory

setRequiredJmsContext

public void setRequiredJmsContext(java.lang.String requiredJmsContext)

Parameters:

requiredJmsContext - the context

setRequiredJmsProviderURL

public void setRequiredJmsProviderURL(java.lang.String requiredJmsProviderURL)

Parameters:

requiredJmsProviderURL - the provider

getMessageListener

protected MessageListener getMessageListener()

The message listener

Overrides:

getMessageListener in class Client

Returns:

the listener.