Package com.swiftmq.impl.streams.comp.io

Class QueueInput

java.lang.Object

com.swiftmq.impl.streams.comp.io.QueueInput

All Implemented Interfaces:

DestinationInput, Input

public class QueueInput
extends java.lang.Object
implements DestinationInput

Consumes Messages from a Queue.

Author:

IIT Software GmbH, Muenster/Germany, (c) 2016, All Rights Reserved

Method Summary

Modifier and Type	Method	Description
void	close()	Closes this Input.
void	collect(long interval)	Internal use.
Message	current()	Returns the current Message of this Input.
Input	current(Message current)	Sets the current Message on this Input.
java.lang.String	destinationName()	Returns the destinationName
DestinationInput	destinationName(java.lang.String destinationName)	Sets the destinationName if different from the name used in stream.create().input(name)
void	executeCallback()	Internal use.
QueueMessageProcessor	getMessageProcessor()	Internal use.
java.lang.String	getName()	Returns the name of this Input.
java.lang.String	getSelector()	Returns the associated JMS Message Selector
DestinationInput	onInput(InputCallback callback)	Sets the onInput callback.
DestinationInput	selector(java.lang.String selector)	Sets the JMS Message Selector
void	setMessageProcessor(QueueMessageProcessor messageProcessor)	Internal use.
void	start()	Starts this Input.
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Method Detail

getMessageProcessor

public QueueMessageProcessor getMessageProcessor()

Description copied from interface: DestinationInput

Internal use.

Specified by:

getMessageProcessor in interface DestinationInput

setMessageProcessor

public void setMessageProcessor(QueueMessageProcessor messageProcessor)

Description copied from interface: DestinationInput

Internal use.

Specified by:

setMessageProcessor in interface DestinationInput

getName

public java.lang.String getName()

Description copied from interface: Input

Returns the name of this Input.

Specified by:

getName in interface Input

Returns:

Name

getSelector

public java.lang.String getSelector()

Description copied from interface: DestinationInput

Returns the associated JMS Message Selector

Specified by:

getSelector in interface DestinationInput

Returns:

JMS Message Selector

selector

public DestinationInput selector(java.lang.String selector)

Description copied from interface: DestinationInput

Sets the JMS Message Selector

Specified by:

selector in interface DestinationInput

Parameters:

selector - JMS Message Selector

Returns:

DestinationInput

destinationName

public DestinationInput destinationName(java.lang.String destinationName)

Description copied from interface: DestinationInput

Sets the destinationName if different from the name used in stream.create().input(name)

Specified by:

destinationName in interface DestinationInput

Parameters:

destinationName - destinationName

Returns:

DestinationInput

destinationName

public java.lang.String destinationName()

Description copied from interface: DestinationInput

Returns the destinationName

Specified by:

destinationName in interface DestinationInput

Returns:

destinationName

current

public Input current(Message current)

Description copied from interface: Input

Sets the current Message on this Input.

Specified by:

current in interface Input

Parameters:

current - Message

Returns:

Input

current

public Message current()

Description copied from interface: Input

Returns the current Message of this Input.

Specified by:

current in interface Input

Returns:

Message

onInput

public DestinationInput onInput(InputCallback callback)

Description copied from interface: DestinationInput

Sets the onInput callback.

Specified by:

onInput in interface DestinationInput

Parameters:

callback - callback

Returns:

DestinationInput

executeCallback

public void executeCallback()
                     throws java.lang.Exception

Description copied from interface: Input

Internal use.

Specified by:

executeCallback in interface Input

Throws:

java.lang.Exception

collect

public void collect(long interval)

Description copied from interface: Input

Internal use.

Specified by:

collect in interface Input

start

public void start()
           throws java.lang.Exception

Description copied from interface: Input

Starts this Input. This method is called automatically if an Input is created outside a callback. If it is created inside, it must be called explicitly.

Specified by:

start in interface Input

Throws:

java.lang.Exception

close

public void close()

Description copied from interface: Input

Closes this Input.

Specified by:

close in interface Input

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object