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

Class TopicInput

java.lang.Object

com.swiftmq.impl.streams.comp.io.TopicInput

All Implemented Interfaces:

DestinationInput, Input

public class TopicInput
extends java.lang.Object
implements DestinationInput

Consumes Messages from a Topic.

Author:

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

Method Summary

Modifier and Type	Method	Description
TopicInput	clientId(java.lang.String clientId)	Sets the client id for a durable subscriber.
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)
TopicInput	durable()	Marks this TopicInput as durable.
TopicInput	durableName(java.lang.String durableName)	Sets the durable name for a durable subscriber.
void	executeCallback()	Internal use.
java.lang.String	getClientId()	Internal use.
java.lang.String	getDurableName()	Internal use.
QueueMessageProcessor	getMessageProcessor()	Internal use.
java.lang.String	getName()	Returns the name of this Input.
java.lang.String	getQueueName()	Internal use.
java.lang.String	getSelector()	Returns the associated JMS Message Selector
int	getSubscriberId()	Internal use.
boolean	isDurable()	Internal use.
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	setName(java.lang.String name)
void	setQueueName(java.lang.String queueName)	Internal use.
void	setSubscriberId(int subscriberId)	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

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

setName

public void setName(java.lang.String 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

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

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

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

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

isDurable

public boolean isDurable()

Internal use.

getClientId

public java.lang.String getClientId()

Internal use.

getDurableName

public java.lang.String getDurableName()

Internal use.

getSubscriberId

public int getSubscriberId()

Internal use.

setSubscriberId

public void setSubscriberId(int subscriberId)

Internal use.

getQueueName

public java.lang.String getQueueName()

Internal use.

setQueueName

public void setQueueName(java.lang.String queueName)

Internal use.

durable

public TopicInput durable()

Marks this TopicInput as durable.

Returns:

TopicInput

clientId

public TopicInput clientId(java.lang.String clientId)

Sets the client id for a durable subscriber.

Parameters:

clientId - client id

Returns:

TopicInput

durableName

public TopicInput durableName(java.lang.String durableName)

Sets the durable name for a durable subscriber.

Parameters:

durableName - durable name

Returns:

TopicInput

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