io.jmix.autoconfigure.eclipselink

Class EclipseLinkHazelcastChanelSupplier.HazelcastMessageChannel

java.lang.Object

io.jmix.autoconfigure.eclipselink.EclipseLinkHazelcastChanelSupplier.HazelcastMessageChannel

All Implemented Interfaces:

org.springframework.messaging.MessageChannel, org.springframework.messaging.SubscribableChannel

Enclosing class:

EclipseLinkHazelcastChanelSupplier

protected static class EclipseLinkHazelcastChanelSupplier.HazelcastMessageChannel
extends java.lang.Object
implements org.springframework.messaging.SubscribableChannel

Field Summary

Fields

Modifier and Type	Field and Description
protected com.hazelcast.topic.ITopic<org.springframework.messaging.Message<?>>	topic

Fields inherited from interface org.springframework.messaging.MessageChannel

INDEFINITE_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
HazelcastMessageChannel(com.hazelcast.topic.ITopic<org.springframework.messaging.Message<?>> topic)

Method Summary

Modifier and Type	Method and Description
boolean	send(org.springframework.messaging.Message<?> message)
boolean	send(org.springframework.messaging.Message<?> message, long timeout)
boolean	subscribe(org.springframework.messaging.MessageHandler handler)
boolean	unsubscribe(org.springframework.messaging.MessageHandler handler)

Methods inherited from class java.lang.Object

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

Field Detail

topic

protected final com.hazelcast.topic.ITopic<org.springframework.messaging.Message<?>> topic

Constructor Detail

HazelcastMessageChannel

public HazelcastMessageChannel(com.hazelcast.topic.ITopic<org.springframework.messaging.Message<?>> topic)

Method Detail

subscribe

public boolean subscribe(org.springframework.messaging.MessageHandler handler)

Specified by:

subscribe in interface org.springframework.messaging.SubscribableChannel

unsubscribe

public boolean unsubscribe(org.springframework.messaging.MessageHandler handler)

Specified by:

unsubscribe in interface org.springframework.messaging.SubscribableChannel

send

public boolean send(org.springframework.messaging.Message<?> message)

Specified by:

send in interface org.springframework.messaging.MessageChannel

send

public boolean send(org.springframework.messaging.Message<?> message,
                    long timeout)

Specified by:

send in interface org.springframework.messaging.MessageChannel