IceStorm

Class _TopicTie

java.lang.Object

Ice.ObjectImpl

IceStorm._TopicDisp

IceStorm._TopicTie

All Implemented Interfaces:

Ice.Object, Ice.TieBase, _TopicOperations, _TopicOperationsNC, Topic, java.io.Serializable, java.lang.Cloneable

public class _TopicTie
extends _TopicDisp
implements Ice.TieBase

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
static long	serialVersionUID

Fields inherited from class IceStorm._TopicDisp

__ids

Fields inherited from interface IceStorm.Topic

ice_staticId

Constructor Summary

Constructors

Constructor and Description
_TopicTie(_TopicOperations delegate)
_TopicTie()

Method Summary

Modifier and Type	Method and Description
void	destroy(Ice.Current __current) Destroy the topic.
boolean	equals(java.lang.Object rhs)
LinkInfo[]	getLinkInfoSeq(Ice.Current __current) Retrieve information on the current links.
java.lang.String	getName(Ice.Current __current) Get the name of this topic.
Ice.ObjectPrx	getNonReplicatedPublisher(Ice.Current __current) Get a non-replicated proxy to a publisher object for this topic.
Ice.ObjectPrx	getPublisher(Ice.Current __current) Get a proxy to a publisher object for this topic.
Ice.Identity[]	getSubscribers(Ice.Current __current) Retrieve the list of subscribers for this topic.
int	hashCode()
java.lang.Object	ice_delegate()
void	ice_delegate(java.lang.Object delegate)
void	link(TopicPrx linkTo, int cost, Ice.Current __current) Create a link to the given topic.
Ice.ObjectPrx	subscribeAndGetPublisher(java.util.Map<java.lang.String,java.lang.String> theQoS, Ice.ObjectPrx subscriber, Ice.Current __current) Subscribe with the given qos to this topic.
void	unlink(TopicPrx linkTo, Ice.Current __current) Destroy the link from this topic to the given topic linkTo.
void	unsubscribe(Ice.ObjectPrx subscriber, Ice.Current __current) Unsubscribe the given subscriber.

Methods inherited from class IceStorm._TopicDisp

___destroy, ___getLinkInfoSeq, ___getName, ___getNonReplicatedPublisher, ___getPublisher, ___getSubscribers, ___link, ___subscribeAndGetPublisher, ___unlink, ___unsubscribe, __dispatch, __readImpl, __writeImpl, destroy, getLinkInfoSeq, getName, getNonReplicatedPublisher, getPublisher, getSubscribers, ice_copyStateFrom, ice_id, ice_id, ice_ids, ice_ids, ice_isA, ice_isA, ice_staticId, link, subscribeAndGetPublisher, unlink, unsubscribe

Methods inherited from class Ice.ObjectImpl

___ice_id, ___ice_ids, ___ice_isA, ___ice_ping, __checkMode, __read, __read, __readImpl, __write, __write, __writeImpl, clone, ice_dispatch, ice_dispatch, ice_operationAttributes, ice_ping, ice_ping, ice_postUnmarshal, ice_preMarshal

Methods inherited from class java.lang.Object

finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface Ice.Object

__read, __read, __write, __write, clone, ice_dispatch, ice_dispatch, ice_operationAttributes, ice_ping, ice_ping, ice_postUnmarshal, ice_preMarshal

Field Detail

serialVersionUID

public static final long serialVersionUID

See Also:

Constant Field Values

Constructor Detail

_TopicTie

public _TopicTie()

_TopicTie

public _TopicTie(_TopicOperations delegate)

Method Detail

ice_delegate

public java.lang.Object ice_delegate()

Specified by:

ice_delegate in interface Ice.TieBase

ice_delegate

public void ice_delegate(java.lang.Object delegate)

Specified by:

ice_delegate in interface Ice.TieBase

equals

public boolean equals(java.lang.Object rhs)

Overrides:

equals in class java.lang.Object

hashCode

public int hashCode()

Overrides:

hashCode in class java.lang.Object

destroy

public void destroy(Ice.Current __current)

Description copied from interface: _TopicOperations

Destroy the topic.

Specified by:

destroy in interface _TopicOperations

Parameters:

__current - The Current object for the invocation.

getLinkInfoSeq

public LinkInfo[] getLinkInfoSeq(Ice.Current __current)

Description copied from interface: _TopicOperations

Retrieve information on the current links.

Specified by:

getLinkInfoSeq in interface _TopicOperations

Parameters:

__current - The Current object for the invocation.

Returns:

A sequence of LinkInfo objects.

getName

public java.lang.String getName(Ice.Current __current)

Description copied from interface: _TopicOperations

Get the name of this topic.

Specified by:

getName in interface _TopicOperations

Parameters:

__current - The Current object for the invocation.

Returns:

The name of the topic.

See Also:

_TopicManagerOperations.create(java.lang.String, Ice.Current)

getNonReplicatedPublisher

public Ice.ObjectPrx getNonReplicatedPublisher(Ice.Current __current)

Description copied from interface: _TopicOperations

Get a non-replicated proxy to a publisher object for this topic. To publish data to a topic, the publisher calls getPublisher and then casts to the topic type. An unchecked cast must be used on this proxy.

Specified by:

getNonReplicatedPublisher in interface _TopicOperations

Parameters:

__current - The Current object for the invocation.

Returns:

A proxy to publish data on this topic.

getPublisher

public Ice.ObjectPrx getPublisher(Ice.Current __current)

Description copied from interface: _TopicOperations

Get a proxy to a publisher object for this topic. To publish data to a topic, the publisher calls getPublisher and then casts to the topic type. An unchecked cast must be used on this proxy. If a replicated IceStorm deployment is used this call may return a replicated proxy.

Specified by:

getPublisher in interface _TopicOperations

Parameters:

__current - The Current object for the invocation.

Returns:

A proxy to publish data on this topic.

getSubscribers

public Ice.Identity[] getSubscribers(Ice.Current __current)

Description copied from interface: _TopicOperations

Retrieve the list of subscribers for this topic.

Specified by:

getSubscribers in interface _TopicOperations

Parameters:

__current - The Current object for the invocation.

Returns:

The sequence of Ice identities for the subscriber objects.

link

public void link(TopicPrx linkTo,
                 int cost,
                 Ice.Current __current)
          throws LinkExists

Description copied from interface: _TopicOperations

Create a link to the given topic. All events originating on this topic will also be sent to linkTo.

Specified by:

link in interface _TopicOperations

Parameters:

linkTo - The topic to link to.

cost - The cost to the linked topic.

__current - The Current object for the invocation.

Throws:

LinkExists - Raised if a link to the same topic already exists.

subscribeAndGetPublisher

public Ice.ObjectPrx subscribeAndGetPublisher(java.util.Map<java.lang.String,java.lang.String> theQoS,
                                              Ice.ObjectPrx subscriber,
                                              Ice.Current __current)
                                       throws AlreadySubscribed,
                                              BadQoS,
                                              InvalidSubscriber

Description copied from interface: _TopicOperations

Subscribe with the given qos to this topic. A per-subscriber publisher object is returned.

Specified by:

subscribeAndGetPublisher in interface _TopicOperations

Parameters:

theQoS - The quality of service parameters for this subscription.

subscriber - The subscriber's proxy.

__current - The Current object for the invocation.

Returns:

The per-subscriber publisher object.

Throws:

AlreadySubscribed - Raised if the subscriber object is already subscribed.

BadQoS - Raised if the requested quality of service is unavailable or invalid.

InvalidSubscriber - Raised if the subscriber object is null.

See Also:

_TopicOperations.unsubscribe(Ice.ObjectPrx, Ice.Current)

unlink

public void unlink(TopicPrx linkTo,
                   Ice.Current __current)
            throws NoSuchLink

Description copied from interface: _TopicOperations

Destroy the link from this topic to the given topic linkTo.

Specified by:

unlink in interface _TopicOperations

Parameters:

linkTo - The topic to destroy the link to.

__current - The Current object for the invocation.

Throws:

NoSuchLink - Raised if a link to the topic does not exist.

unsubscribe

public void unsubscribe(Ice.ObjectPrx subscriber,
                        Ice.Current __current)

Description copied from interface: _TopicOperations

Unsubscribe the given subscriber.

Specified by:

unsubscribe in interface _TopicOperations

Parameters:

subscriber - The proxy of an existing subscriber.

__current - The Current object for the invocation.

See Also:

_TopicOperations.subscribeAndGetPublisher(java.util.Map<java.lang.String, java.lang.String>, Ice.ObjectPrx, Ice.Current)