Class StreamLibDeployer

java.lang.Object

com.swiftmq.swiftlet.queue.MessageProcessor

com.swiftmq.impl.streams.StreamLibDeployer

All Implemented Interfaces:

com.swiftmq.swiftlet.threadpool.AsyncTask, Runnable

public class StreamLibDeployer
extends com.swiftmq.swiftlet.queue.MessageProcessor

Constructor Summary

Constructors

Constructor	Description
StreamLibDeployer(SwiftletContext ctx)

Method Summary

Modifier and Type	Method	Description
void	close()
String	getDescription()
String	getDispatchToken()
boolean	isValid()
static String	loadAsString(File f)
void	processException(Exception e)
void	processMessage(com.swiftmq.swiftlet.queue.MessageEntry entry)
void	removeStreamLibs(String fqn)
void	run()
void	stop()
String	toString()

Methods inherited from class com.swiftmq.swiftlet.queue.MessageProcessor

createBulkBuffer, getBulkBuffer, getCurrentBulkSize, getMaxBulkSize, getReceiverId, getRegistrationId, getRegistrationTime, getSelector, getTimeout, getTransactionId, getViewId, isAutoCommit, isBulkMode, processMessages, reset, setAutoCommit, setBulkMode, setCurrentBulkSize, setReceiverId, setRegistrationId, setRegistrationTime, setTransactionId, setViewId

Methods inherited from class Object

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

Constructor Details

StreamLibDeployer

public StreamLibDeployer(SwiftletContext ctx)
                  throws Exception

Throws:

Exception

Method Details

isValid

public boolean isValid()

processMessage

public void processMessage(com.swiftmq.swiftlet.queue.MessageEntry entry)

Specified by:

processMessage in class com.swiftmq.swiftlet.queue.MessageProcessor

processException

public void processException(Exception e)

Specified by:

processException in class com.swiftmq.swiftlet.queue.MessageProcessor

getDispatchToken

public String getDispatchToken()

Specified by:

getDispatchToken in interface com.swiftmq.swiftlet.threadpool.AsyncTask

Overrides:

getDispatchToken in class com.swiftmq.swiftlet.queue.MessageProcessor

getDescription

public String getDescription()

Specified by:

getDescription in interface com.swiftmq.swiftlet.threadpool.AsyncTask

Overrides:

getDescription in class com.swiftmq.swiftlet.queue.MessageProcessor

loadAsString

public static String loadAsString(File f)
                           throws Exception

Throws:

Exception

removeStreamLibs

public void removeStreamLibs(String fqn)

run

public void run()

Specified by:

run in interface com.swiftmq.swiftlet.threadpool.AsyncTask

Specified by:

run in interface Runnable

Overrides:

run in class com.swiftmq.swiftlet.queue.MessageProcessor

stop

public void stop()

Specified by:

stop in interface com.swiftmq.swiftlet.threadpool.AsyncTask

Overrides:

stop in class com.swiftmq.swiftlet.queue.MessageProcessor

close

public void close()

toString

public String toString()

Overrides:

toString in class Object