org.safs.staf.service.queue

Class EmbeddedQueueService

java.lang.Object

org.safs.staf.service.queue.EmbeddedQueueService

All Implemented Interfaces:

ServiceInterface

public class EmbeddedQueueService
extends java.lang.Object
implements ServiceInterface

History:

Jul 17, 2014 (Lei Wang) Initial release.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	EmbeddedQueueService.SendMessageThread

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	COMMAND_GET
static java.lang.String	COMMAND_QUEUE
static java.lang.String	DEFAULT_HANDLE_ID
static java.lang.String	DEFAULT_SERVICE_NAME
protected EmbeddedServiceHandle	fHandle
protected java.lang.String	handleID
static java.lang.String	OPTION_MESSAGE
static java.lang.String	OPTION_NAME
static java.lang.String	OPTION_WAIT
protected com.ibm.staf.service.STAFCommandParser	parser
protected java.lang.String	servicename

Constructor Summary

Constructors

Constructor and Description
EmbeddedQueueService()

Method Summary

Modifier and Type	Method and Description
com.ibm.staf.STAFResult	acceptRequest(InfoInterface.RequestInfo info)
com.ibm.staf.STAFResult	get(com.ibm.staf.service.STAFCommandParseResult param)
java.lang.String	getHandleID()
com.ibm.staf.STAFResult	init(InfoInterface.InitInfo initInfo)
static void	main(java.lang.String[] args) This is used to test the queue service.
com.ibm.staf.STAFResult	queue(com.ibm.staf.service.STAFCommandParseResult param)
com.ibm.staf.STAFResult	terminate()
com.ibm.staf.STAFResult	terminateService()

Methods inherited from class java.lang.Object

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

Field Detail

DEFAULT_HANDLE_ID

public static final java.lang.String DEFAULT_HANDLE_ID

See Also:

Constant Field Values

DEFAULT_SERVICE_NAME

public static final java.lang.String DEFAULT_SERVICE_NAME

See Also:

Constant Field Values

COMMAND_QUEUE

public static final java.lang.String COMMAND_QUEUE

See Also:

Constant Field Values

COMMAND_GET

public static final java.lang.String COMMAND_GET

See Also:

Constant Field Values

OPTION_NAME

public static final java.lang.String OPTION_NAME

See Also:

Constant Field Values

OPTION_WAIT

public static final java.lang.String OPTION_WAIT

See Also:

Constant Field Values

OPTION_MESSAGE

public static final java.lang.String OPTION_MESSAGE

See Also:

Constant Field Values

fHandle

protected EmbeddedServiceHandle fHandle

servicename

protected java.lang.String servicename

handleID

protected java.lang.String handleID

parser

protected com.ibm.staf.service.STAFCommandParser parser

Constructor Detail

EmbeddedQueueService

public EmbeddedQueueService()

Method Detail

init

public com.ibm.staf.STAFResult init(InfoInterface.InitInfo initInfo)

acceptRequest

public com.ibm.staf.STAFResult acceptRequest(InfoInterface.RequestInfo info)

Specified by:

acceptRequest in interface ServiceInterface

queue

public com.ibm.staf.STAFResult queue(com.ibm.staf.service.STAFCommandParseResult param)

get

public com.ibm.staf.STAFResult get(com.ibm.staf.service.STAFCommandParseResult param)

terminate

public com.ibm.staf.STAFResult terminate()

getHandleID

public java.lang.String getHandleID()

main

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

This is used to test the queue service. Send 10 messages to Default_Queue, 10 messages to
queue 'MyQueue1' and 5 messages to queue 'MyQueue2'. Finally get these queued messages one by one.

terminateService

public com.ibm.staf.STAFResult terminateService()

Specified by:

terminateService in interface ServiceInterface