com.mulesoft.mule.runtime.module.cluster.internal.vm

Class ClusterQueueStore

java.lang.Object

com.mulesoft.mule.runtime.module.cluster.internal.serialization.SerializationSaavyQueueSupport

com.mulesoft.mule.runtime.module.cluster.internal.vm.ClusterQueueStore

All Implemented Interfaces:

org.mule.runtime.api.lifecycle.Startable, org.mule.runtime.api.lifecycle.Stoppable, org.mule.runtime.core.internal.util.queue.QueueStore

public class ClusterQueueStore
extends SerializationSaavyQueueSupport
implements org.mule.runtime.core.internal.util.queue.QueueStore, org.mule.runtime.api.lifecycle.Startable, org.mule.runtime.api.lifecycle.Stoppable

Field Summary

Fields inherited from interface org.mule.runtime.api.lifecycle.Startable

PHASE_NAME

Fields inherited from interface org.mule.runtime.api.lifecycle.Stoppable

PHASE_NAME

Constructor Summary

Constructors

Constructor and Description
ClusterQueueStore(String name, org.mule.runtime.core.api.util.queue.QueueConfiguration config, com.hazelcast.core.IQueue<Object> queue, org.mule.runtime.api.serialization.ObjectSerializer objectSerializer)

Method Summary

Modifier and Type	Method and Description
void	clear()
void	close()
void	dispose()
int	getCapacity()
String	getName()
int	getSize()
boolean	isPersistent()
boolean	offer(Serializable o, int room, long timeout)
Serializable	peek()
Serializable	poll(long timeout)
void	putNow(Serializable o)
void	start()
void	stop()
String	toString()
void	untake(Serializable item)

Methods inherited from class com.mulesoft.mule.runtime.module.cluster.internal.serialization.SerializationSaavyQueueSupport

deserialize, serialize

Methods inherited from class java.lang.Object

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

Constructor Detail

ClusterQueueStore

public ClusterQueueStore(String name,
                         org.mule.runtime.core.api.util.queue.QueueConfiguration config,
                         com.hazelcast.core.IQueue<Object> queue,
                         org.mule.runtime.api.serialization.ObjectSerializer objectSerializer)

Method Detail

getName

public String getName()

Specified by:

getName in interface org.mule.runtime.core.internal.util.queue.QueueStore

putNow

public void putNow(Serializable o)
            throws InterruptedException

Specified by:

putNow in interface org.mule.runtime.core.internal.util.queue.QueueStore

Throws:

InterruptedException

offer

public boolean offer(Serializable o,
                     int room,
                     long timeout)
              throws InterruptedException

Specified by:

offer in interface org.mule.runtime.core.internal.util.queue.QueueStore

Throws:

InterruptedException

poll

public Serializable poll(long timeout)
                  throws InterruptedException

Specified by:

poll in interface org.mule.runtime.core.internal.util.queue.QueueStore

Throws:

InterruptedException

peek

public Serializable peek()
                  throws InterruptedException

Specified by:

peek in interface org.mule.runtime.core.internal.util.queue.QueueStore

Throws:

InterruptedException

untake

public void untake(Serializable item)
            throws InterruptedException

Specified by:

untake in interface org.mule.runtime.core.internal.util.queue.QueueStore

Throws:

InterruptedException

getSize

public int getSize()

Specified by:

getSize in interface org.mule.runtime.core.internal.util.queue.QueueStore

clear

public void clear()
           throws InterruptedException

Specified by:

clear in interface org.mule.runtime.core.internal.util.queue.QueueStore

Throws:

InterruptedException

dispose

public void dispose()

Specified by:

dispose in interface org.mule.runtime.core.internal.util.queue.QueueStore

getCapacity

public int getCapacity()

Specified by:

getCapacity in interface org.mule.runtime.core.internal.util.queue.QueueStore

close

public void close()

Specified by:

close in interface org.mule.runtime.core.internal.util.queue.QueueStore

isPersistent

public boolean isPersistent()

Specified by:

isPersistent in interface org.mule.runtime.core.internal.util.queue.QueueStore

start

public void start()
           throws org.mule.runtime.api.exception.MuleException

Specified by:

start in interface org.mule.runtime.api.lifecycle.Startable

Throws:

org.mule.runtime.api.exception.MuleException

stop

public void stop()
          throws org.mule.runtime.api.exception.MuleException

Specified by:

stop in interface org.mule.runtime.api.lifecycle.Stoppable

Throws:

org.mule.runtime.api.exception.MuleException

toString

public String toString()

Overrides:

toString in class Object