io.crossbar.autobahn.wamp.interfaces

Interface ISession

All Known Implementing Classes:

Session

public interface ISession

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	ISession.OnConnectListener
static interface	ISession.OnDisconnectListener
static interface	ISession.OnJoinListener
static interface	ISession.OnLeaveListener
static interface	ISession.OnReadyListener
static interface	ISession.OnUserErrorListener

Method Summary

Modifier and Type	Method and Description
<T> java.util.concurrent.CompletableFuture<T>	call(java.lang.String procedure, <any> resultType, CallOptions options, java.lang.Object... args)
<T> java.util.concurrent.CompletableFuture<T>	call(java.lang.String procedure, java.util.List<java.lang.Object> args, java.util.Map<java.lang.String,java.lang.Object> kwargs, <any> resultType, CallOptions options)
java.util.concurrent.CompletableFuture<CallResult>	call(java.lang.String procedure, java.util.List<java.lang.Object> args, java.util.Map<java.lang.String,java.lang.Object> kwargs, CallOptions options)
boolean	isConnected()
java.util.concurrent.CompletableFuture<SessionDetails>	join(java.lang.String realm, java.util.List<java.lang.String> authMethods)
void	leave(java.lang.String reason, java.lang.String message)
java.util.concurrent.CompletableFuture<Publication>	publish(java.lang.String topic)
java.util.concurrent.CompletableFuture<Publication>	publish(java.lang.String topic, java.util.List<java.lang.Object> args, java.util.Map<java.lang.String,java.lang.Object> kwargs, PublishOptions options)
java.util.concurrent.CompletableFuture<Publication>	publish(java.lang.String topic, java.lang.Object... objects)
java.util.concurrent.CompletableFuture<Publication>	publish(java.lang.String topic, java.lang.Object object, PublishOptions options)
java.util.concurrent.CompletableFuture<Publication>	publish(java.lang.String topic, PublishOptions options)
java.util.concurrent.CompletableFuture<Publication>	publish(java.lang.String topic, PublishOptions options, java.lang.Object... objects)
<T> java.util.concurrent.CompletableFuture<Registration>	register(java.lang.String procedure, java.util.function.BiFunction<T,InvocationDetails,java.util.concurrent.CompletableFuture<InvocationResult>> endpoint, RegisterOptions options)
<T> java.util.concurrent.CompletableFuture<Registration>	register(java.lang.String procedure, java.util.function.Function<T,java.util.concurrent.CompletableFuture<InvocationResult>> endpoint, RegisterOptions options)
java.util.concurrent.CompletableFuture<Registration>	register(java.lang.String procedure, IInvocationHandler endpoint, RegisterOptions options)
java.util.concurrent.CompletableFuture<Registration>	register(java.lang.String procedure, java.util.function.Supplier<java.util.concurrent.CompletableFuture<InvocationResult>> endpoint, RegisterOptions options)
<T,U> java.util.concurrent.CompletableFuture<Registration>	register(java.lang.String procedure, TriFunction<T,U,InvocationDetails,java.util.concurrent.CompletableFuture<InvocationResult>> endpoint, RegisterOptions options)
<T> java.util.concurrent.CompletableFuture<Subscription>	subscribe(java.lang.String topic, java.util.function.BiConsumer<T,EventDetails> handler, SubscribeOptions options)
<T> java.util.concurrent.CompletableFuture<Subscription>	subscribe(java.lang.String topic, java.util.function.BiFunction<T,EventDetails,java.util.concurrent.CompletableFuture<ReceptionResult>> handler, SubscribeOptions options)
<T> java.util.concurrent.CompletableFuture<Subscription>	subscribe(java.lang.String topic, java.util.function.Consumer<T> handler, SubscribeOptions options)
<T> java.util.concurrent.CompletableFuture<Subscription>	subscribe(java.lang.String topic, java.util.function.Function<T,java.util.concurrent.CompletableFuture<ReceptionResult>> handler, SubscribeOptions options)
<T,U> java.util.concurrent.CompletableFuture<Subscription>	subscribe(java.lang.String topic, TriConsumer<T,U,EventDetails> handler, SubscribeOptions options)
<T,U> java.util.concurrent.CompletableFuture<Subscription>	subscribe(java.lang.String topic, TriFunction<T,U,EventDetails,java.util.concurrent.CompletableFuture<ReceptionResult>> handler, SubscribeOptions options)

Method Detail

subscribe

<T> java.util.concurrent.CompletableFuture<Subscription> subscribe(java.lang.String topic,
                                                                   java.util.function.Consumer<T> handler,
                                                                   SubscribeOptions options)

subscribe

<T> java.util.concurrent.CompletableFuture<Subscription> subscribe(java.lang.String topic,
                                                                   java.util.function.Function<T,java.util.concurrent.CompletableFuture<ReceptionResult>> handler,
                                                                   SubscribeOptions options)

subscribe

<T> java.util.concurrent.CompletableFuture<Subscription> subscribe(java.lang.String topic,
                                                                   java.util.function.BiConsumer<T,EventDetails> handler,
                                                                   SubscribeOptions options)

subscribe

<T> java.util.concurrent.CompletableFuture<Subscription> subscribe(java.lang.String topic,
                                                                   java.util.function.BiFunction<T,EventDetails,java.util.concurrent.CompletableFuture<ReceptionResult>> handler,
                                                                   SubscribeOptions options)

subscribe

<T,U> java.util.concurrent.CompletableFuture<Subscription> subscribe(java.lang.String topic,
                                                                     TriConsumer<T,U,EventDetails> handler,
                                                                     SubscribeOptions options)

subscribe

<T,U> java.util.concurrent.CompletableFuture<Subscription> subscribe(java.lang.String topic,
                                                                     TriFunction<T,U,EventDetails,java.util.concurrent.CompletableFuture<ReceptionResult>> handler,
                                                                     SubscribeOptions options)

publish

java.util.concurrent.CompletableFuture<Publication> publish(java.lang.String topic,
                                                            java.util.List<java.lang.Object> args,
                                                            java.util.Map<java.lang.String,java.lang.Object> kwargs,
                                                            PublishOptions options)

publish

java.util.concurrent.CompletableFuture<Publication> publish(java.lang.String topic,
                                                            java.lang.Object object,
                                                            PublishOptions options)

publish

java.util.concurrent.CompletableFuture<Publication> publish(java.lang.String topic,
                                                            PublishOptions options,
                                                            java.lang.Object... objects)

publish

java.util.concurrent.CompletableFuture<Publication> publish(java.lang.String topic,
                                                            java.lang.Object... objects)

publish

java.util.concurrent.CompletableFuture<Publication> publish(java.lang.String topic,
                                                            PublishOptions options)

publish

java.util.concurrent.CompletableFuture<Publication> publish(java.lang.String topic)

register

java.util.concurrent.CompletableFuture<Registration> register(java.lang.String procedure,
                                                              java.util.function.Supplier<java.util.concurrent.CompletableFuture<InvocationResult>> endpoint,
                                                              RegisterOptions options)

register

java.util.concurrent.CompletableFuture<Registration> register(java.lang.String procedure,
                                                              IInvocationHandler endpoint,
                                                              RegisterOptions options)

register

<T> java.util.concurrent.CompletableFuture<Registration> register(java.lang.String procedure,
                                                                  java.util.function.Function<T,java.util.concurrent.CompletableFuture<InvocationResult>> endpoint,
                                                                  RegisterOptions options)

register

<T> java.util.concurrent.CompletableFuture<Registration> register(java.lang.String procedure,
                                                                  java.util.function.BiFunction<T,InvocationDetails,java.util.concurrent.CompletableFuture<InvocationResult>> endpoint,
                                                                  RegisterOptions options)

register

<T,U> java.util.concurrent.CompletableFuture<Registration> register(java.lang.String procedure,
                                                                    TriFunction<T,U,InvocationDetails,java.util.concurrent.CompletableFuture<InvocationResult>> endpoint,
                                                                    RegisterOptions options)

call

java.util.concurrent.CompletableFuture<CallResult> call(java.lang.String procedure,
                                                        java.util.List<java.lang.Object> args,
                                                        java.util.Map<java.lang.String,java.lang.Object> kwargs,
                                                        CallOptions options)

call

<T> java.util.concurrent.CompletableFuture<T> call(java.lang.String procedure,
                                                   java.util.List<java.lang.Object> args,
                                                   java.util.Map<java.lang.String,java.lang.Object> kwargs,
                                                   <any> resultType,
                                                   CallOptions options)

call

<T> java.util.concurrent.CompletableFuture<T> call(java.lang.String procedure,
                                                   <any> resultType,
                                                   CallOptions options,
                                                   java.lang.Object... args)

join

java.util.concurrent.CompletableFuture<SessionDetails> join(java.lang.String realm,
                                                            java.util.List<java.lang.String> authMethods)

leave

void leave(java.lang.String reason,
           java.lang.String message)

isConnected

boolean isConnected()