com.hazelcast.map.impl.querycache

Class NodeQueryCacheContext

java.lang.Object

com.hazelcast.map.impl.querycache.NodeQueryCacheContext

All Implemented Interfaces:

QueryCacheContext

public class NodeQueryCacheContext
extends Object
implements QueryCacheContext

Node side implementation of QueryCacheContext.

See Also:

QueryCacheContext

Constructor Summary

Constructors

Constructor and Description
NodeQueryCacheContext(MapServiceContext mapServiceContext)

Method Summary

Modifier and Type	Method and Description
void	destroy() Destroys everything in this context.
protected void	flushPublishersOnNodeShutdown() This is a best effort approach; there is no guarantee that events in publishers internal buffers will be fired, EventService can drop them.
InvokerWrapper	getInvokerWrapper() Returns InvokerWrapper for this context.
Collection<Member>	getMemberList() Returns member list of the cluster.
int	getPartitionId(Object object) Returns partition id of the supplied object.
PublisherContext	getPublisherContext() Returns PublisherContext for this context.
QueryCacheConfigurator	getQueryCacheConfigurator() Returns QueryCacheConfigurator for this context which will be used to create QueryCacheConfigurator implementations for client or node sides.
QueryCacheEventService	getQueryCacheEventService() Returns QueryCacheEventService factory for this context which will be used to create QueryCacheEventService implementations for client or node sides.
QueryCacheScheduler	getQueryCacheScheduler() Returns QueryCacheScheduler for this context which will be used to create QueryCacheScheduler implementations for client or node sides.
InternalSerializationService	getSerializationService() Returns InternalSerializationService for this context.
SubscriberContext	getSubscriberContext() Returns SubscriberContext for this context.
Address	getThisNodesAddress() Returns this nodes address.
void	setSubscriberContext(SubscriberContext subscriberContext) Only used for testing purposes.
Object	toObject(Object obj) Helper method to convert provided Data to its object form.

Methods inherited from class java.lang.Object

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

Constructor Detail

NodeQueryCacheContext

public NodeQueryCacheContext(MapServiceContext mapServiceContext)

Method Detail

flushPublishersOnNodeShutdown

protected void flushPublishersOnNodeShutdown()

This is a best effort approach; there is no guarantee that events in publishers internal buffers will be fired, EventService can drop them.

destroy

public void destroy()

Description copied from interface: QueryCacheContext

Destroys everything in this context.

Specified by:

destroy in interface QueryCacheContext

getPublisherContext

public PublisherContext getPublisherContext()

Description copied from interface: QueryCacheContext

Returns PublisherContext for this context.

Specified by:

getPublisherContext in interface QueryCacheContext

Returns:

PublisherContext

See Also:

PublisherContext

getSubscriberContext

public SubscriberContext getSubscriberContext()

Description copied from interface: QueryCacheContext

Returns SubscriberContext for this context.

Specified by:

getSubscriberContext in interface QueryCacheContext

Returns:

SubscriberContext for this context.

See Also:

SubscriberContext

setSubscriberContext

public void setSubscriberContext(SubscriberContext subscriberContext)

Description copied from interface: QueryCacheContext

Only used for testing purposes.

Sets SubscriberContext implementation used by this query-cache context.

Specified by:

setSubscriberContext in interface QueryCacheContext

Parameters:

subscriberContext - the supplied subscriberContext to be set.

getQueryCacheEventService

public QueryCacheEventService getQueryCacheEventService()

Description copied from interface: QueryCacheContext

Returns QueryCacheEventService factory for this context which will be used to create QueryCacheEventService implementations for client or node sides.

Specified by:

getQueryCacheEventService in interface QueryCacheContext

Returns:

QueryCacheEventService for this context.

getQueryCacheConfigurator

public QueryCacheConfigurator getQueryCacheConfigurator()

Description copied from interface: QueryCacheContext

Returns QueryCacheConfigurator for this context which will be used to create QueryCacheConfigurator implementations for client or node sides.

Specified by:

getQueryCacheConfigurator in interface QueryCacheContext

Returns:

QueryCacheConfigurator for this context.

getQueryCacheScheduler

public QueryCacheScheduler getQueryCacheScheduler()

Description copied from interface: QueryCacheContext

Returns QueryCacheScheduler for this context which will be used to create QueryCacheScheduler implementations for client or node sides.

Specified by:

getQueryCacheScheduler in interface QueryCacheContext

Returns:

QueryCacheScheduler for this context.

getSerializationService

public InternalSerializationService getSerializationService()

Description copied from interface: QueryCacheContext

Returns InternalSerializationService for this context.

Specified by:

getSerializationService in interface QueryCacheContext

Returns:

InternalSerializationService for this context.

getThisNodesAddress

public Address getThisNodesAddress()

Description copied from interface: QueryCacheContext

Returns this nodes address.

Specified by:

getThisNodesAddress in interface QueryCacheContext

Returns:

this nodes address.

getMemberList

public Collection<Member> getMemberList()

Description copied from interface: QueryCacheContext

Returns member list of the cluster. This will be used to send operations to all nodes.

Specified by:

getMemberList in interface QueryCacheContext

Returns:

Member list of the cluster.

getPartitionId

public int getPartitionId(Object object)

Description copied from interface: QueryCacheContext

Returns partition id of the supplied object.

Specified by:

getPartitionId in interface QueryCacheContext

Parameters:

object - supplied object.

Returns:

partition id

getInvokerWrapper

public InvokerWrapper getInvokerWrapper()

Description copied from interface: QueryCacheContext

Returns InvokerWrapper for this context.

Specified by:

getInvokerWrapper in interface QueryCacheContext

Returns:

InvokerWrapper for this context.

toObject

public Object toObject(Object obj)

Description copied from interface: QueryCacheContext

Helper method to convert provided Data to its object form.

Specified by:

toObject in interface QueryCacheContext

Parameters:

obj - this object may possibly be an instance of Data type.

Returns:

a new object.