Modifier and Type	Class and Description
private class	Serializer.SerializerQueue

Modifier and Type

Class and Description

private class

Serializer.SerializerQueue

Modifier and Type	Field and Description
private final ContextInternal	ctx
private final Map<String, Serializer.SerializerQueue>	queues

Modifier and Type

Field and Description

private final ContextInternal

ctx

private final Map<String, Serializer.SerializerQueue>

queues

Access	Constructor and Description
private	Serializer(ContextInternal context)

Access

Constructor and Description

private

Serializer(ContextInternal context)

Method Summary

Modifier and Type	Method and Description
public void	close(Promise<Void> the promise to signal when close has completed completion) Implements io.vertx.core.Closeable.close. Close this resource, the `completion` promise must be notified when the operation has completed.
public static Serializer	get(ContextInternal context)
public <T> void	queue(Message<?> message, BiConsumer<Message<?>, Promise<T>> selectHandler, Promise<T> promise)

Modifier and Type

Method and Description

public void

close(Promise<Void>

the promise to signal when close has completed

completion)

Implements io.vertx.core.Closeable.close.

Close this resource, the completion promise must be notified when the operation has completed.

public static Serializer

get(ContextInternal context)

public <T> void

queue(Message<?> message, BiConsumer<Message<?>, Promise<T>> selectHandler, Promise<T> promise)

ctx	back to summary
private final ContextInternal ctx

ctx

back to summary

private final ContextInternal ctx

queues	back to summary
private final Map<String, Serializer.SerializerQueue> queues

queues

back to summary

private final Map<String, Serializer.SerializerQueue> queues

Serializer	back to summary
private Serializer(ContextInternal context)

Serializer

back to summary

private Serializer(ContextInternal context)

Method Detail

close	back to summary
public void close(Promise<Void> completion) Implements io.vertx.core.Closeable.close. Doc from io.vertx.core.Closeable.close. Close this resource, the `completion` promise must be notified when the operation has completed. Parameters completion:Promise<Void> the promise to signal when close has completed Annotations @Override

back to summary

public void close(Promise<Void> completion)

Implements io.vertx.core.Closeable.close.

Doc from io.vertx.core.Closeable.close.

Close this resource, the completion promise must be notified when the operation has completed.

Parameters

completion:Promise<Void>: the promise to signal when close has completed

Annotations

@Override

get	back to summary
public static Serializer get(ContextInternal context)

get

back to summary

public static Serializer get(ContextInternal context)

queue	back to summary
public <T> void queue(Message<?> message, BiConsumer<Message<?>, Promise<T>> selectHandler, Promise<T> promise)

queue

back to summary

public <T> void queue(Message<?> message, BiConsumer<Message<?>, Promise<T>> selectHandler, Promise<T> promise)

io.vertx.core.eventbus.impl.clustered back to summary

private Class Serializer.SerializerQueue

Class Inheritance

extends Object

java.lang.Object
io.vertx.core.eventbus.impl.clustered.Serializer.SerializerQueue

Nested and Inner Type Summary

Modifier and Type	Class and Description
private class	Serializer.SerializerQueue.SerializedTask<U>

Field Summary

Modifier and Type	Field and Description
private final String	address
private boolean	closed
private boolean	running
private final Queue<Serializer.SerializerQueue.SerializedTask<?>>	tasks

Constructor Summary

Access	Constructor and Description
pack-priv	SerializerQueue(String address)

Method Summary

Modifier and Type	Method and Description
pack-priv <U> void	add(Message<?> msg, BiConsumer<Message<?>, Promise<U>> selectHandler, Promise<U> promise)
pack-priv void	checkPending()
pack-priv void	close()
pack-priv void	processed()

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

address	back to summary
private final String address

closed	back to summary
private boolean closed

running	back to summary
private boolean running

tasks	back to summary
private final Queue<Serializer.SerializerQueue.SerializedTask<?>> tasks

Constructor Detail

SerializerQueue	back to summary
pack-priv SerializerQueue(String address)

Method Detail

add	back to summary
pack-priv <U> void add(Message<?> msg, BiConsumer<Message<?>, Promise<U>> selectHandler, Promise<U> promise)

checkPending	back to summary
pack-priv void checkPending()

close	back to summary
pack-priv void close()

processed	back to summary
pack-priv void processed()

io.vertx.core.eventbus.impl.clustered back to summary

private Class Serializer.SerializerQueue.SerializedTask<U>

Class Inheritance

extends Object
implements Handler<AsyncResult<U>>

java.lang.Object
io.vertx.core.eventbus.impl.clustered.Serializer.SerializerQueue.SerializedTask

All Implemented Interfaces

io.vertx.core.Handler

Field Summary

Modifier and Type	Field and Description
pack-priv final Promise<U>	internalPromise
pack-priv final Message<?>	msg
pack-priv final BiConsumer<Message<?>, Promise<U>>	selectHandler

Constructor Summary

Access	Constructor and Description
pack-priv	SerializedTask(ContextInternal context, Message<?> msg, BiConsumer<Message<?>, Promise<U>> selectHandler)

Method Summary

Modifier and Type	Method and Description
public void	handle(AsyncResult<U> the event to handle ar) Implements io.vertx.core.Handler.handle. Something has happened, so handle it.
pack-priv void	process()

Inherited from java.lang.Object:: clone equals finalize getClass hashCode notify notifyAll toString wait wait wait

Field Detail

internalPromise	back to summary
pack-priv final Promise<U> internalPromise

msg	back to summary
pack-priv final Message<?> msg

selectHandler	back to summary
pack-priv final BiConsumer<Message<?>, Promise<U>> selectHandler

Constructor Detail

SerializedTask	back to summary
pack-priv SerializedTask(ContextInternal context, Message<?> msg, BiConsumer<Message<?>, Promise<U>> selectHandler)

Method Detail

handle	back to summary
public void handle(AsyncResult<U> ar) Implements io.vertx.core.Handler.handle. Doc from io.vertx.core.Handler.handle. Something has happened, so handle it. Parameters ar:AsyncResult<U> the event to handle Annotations @Override

handle

back to summary

public void handle(AsyncResult<U> ar)

Implements io.vertx.core.Handler.handle.

Doc from io.vertx.core.Handler.handle.

Something has happened, so handle it.

Parameters

ar:AsyncResult<U>: the event to handle

Annotations

@Override

process	back to summary
pack-priv void process()

public Class Serializer

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class Serializer.SerializerQueue

Nested and Inner Type Summary

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail

private Class Serializer.SerializerQueue.SerializedTask<U>

Field Summary

Constructor Summary

Method Summary

Field Detail

Constructor Detail

Method Detail