Package org.forum.client

Class SubscriptionReactiveExecutorForum

java.lang.Object

org.forum.client.SubscriptionReactiveExecutorForum

All Implemented Interfaces:

GraphQLSubscriptionReactiveExecutor

@Component
public class SubscriptionReactiveExecutorForum
extends Object
implements GraphQLSubscriptionReactiveExecutor

This class contains the methods that allows the execution of the subscriptions that are defined in the Subscription of the GraphQL schema. All the methods for this executor are in spring reactive, that is: they return a Flux.
These methods allows:

• Preparation of partial subscription requests
• Execution of partial prepared subscription requests
• Execution of partial direct subscription requests

You'll find all the documentation on the client page doc.

Author:

generated by graphql-java-generator

Constructor Summary

Constructors

Constructor	Description
SubscriptionReactiveExecutorForum()

Method Summary

Modifier and Type	Method	Description
reactor.core.publisher.Flux<Subscription>	exec(ObjectResponse objectResponse, Object... paramsAndValues)	This method takes a subscription full request definition, and executes it in reactive mode against the GraphQL server.
reactor.core.publisher.Flux<Subscription>	exec(String queryResponseDef, Object... paramsAndValues)	This method takes a subscription full request definition, and executes it in reactive mode against the GraphQL server.
reactor.core.publisher.Flux<Subscription>	execWithBindValues(ObjectResponse objectResponse, Map<String,Object> parameters)	This method takes a subscription full request definition, and executes it in reactive mode against the GraphQL server.
reactor.core.publisher.Flux<Subscription>	execWithBindValues(String queryResponseDef, Map<String,Object> parameters)	This method takes a subscription full request definition, and executes it in reactive mode against the GraphQL server.
GraphQLReactiveRequestForum	getGraphQLRequest(String fullRequest)	Get the GraphQLRequestForum for full request.
Builder	getResponseBuilder()	Get the Builder for a full request, as expected by the exec and execWithBindValues methods.
GraphQLReactiveRequestForum	getSubscribeToNewPostGraphQLRequest(String partialRequest)	Get the GraphQLRequestForum for the subscribeToNewPost REACTIVE_EXECUTOR, created with the given Partial request.
Builder	getSubscribeToNewPostResponseBuilder()	Get the Builder for the Post, as expected by the subscribeToNewPost subscription.
reactor.core.publisher.Flux<Optional<Post>>	subscribeToNewPost(ObjectResponse objectResponse, String boardName, Object... paramsAndValues)	This method registers a subscription, by executing a direct partial request against the GraphQL server.
reactor.core.publisher.Flux<Optional<Post>>	subscribeToNewPost(String queryResponseDef, String boardName, Object... paramsAndValues)	This method registers a subscription, by executing a direct partial request against the GraphQL server.
reactor.core.publisher.Flux<Optional<Post>>	subscribeToNewPostWithBindValues(ObjectResponse objectResponse, String boardName, Map<String,Object> parameters)	This method registers a subscription, by executing a direct partial request against the GraphQL server.
reactor.core.publisher.Flux<Optional<Post>>	subscribeToNewPostWithBindValues(String queryResponseDef, String boardName, Map<String,Object> parameters)	This method registers a subscription, by executing a direct partial subscribeToNewPost subscription against the GraphQL server.

Methods inherited from class java.lang.Object

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

Constructor Details

SubscriptionReactiveExecutorForum

public SubscriptionReactiveExecutorForum()

Method Details

execWithBindValues

public reactor.core.publisher.Flux<Subscription> execWithBindValues(String queryResponseDef,
 Map<String,Object> parameters)
                                                             throws GraphQLRequestExecutionException,
GraphQLRequestPreparationException

This method takes a subscription full request definition, and executes it in reactive mode against the GraphQL server. It may only return one subscription's field.
It offers a logging of the call (if in debug mode), or of the call and its parameters (if in trace mode).
Here is a sample on how to use it:

Parameters:

queryResponseDef - The response definition of the subscription, in the native GraphQL format (see here above). It must ommit the query/mutation/subscription keyword, and start by the first { that follows.It may contain directives, as explained in the GraphQL specs.

parameters - The map of values, for the bind variables defined in the query. If there is no bind variable in the defined Query, this argument may be null or an empty Map. The key is the parameter name, as defined in the query (in the above sample: heroParam is an optional parameter and skip is a mandatory one). The value is the parameter vale in its Java type (for instance a Date for the GraphQLScalarTypeDate). The parameters which value is missing in this map will no be transmitted toward the GraphQL server.

Returns:

The SubscriptionClient that allows the caller to act on the subscribed subscription.

Throws:

GraphQLRequestPreparationException - When an error occurs during the request preparation, typically when building the ObjectResponse

GraphQLRequestExecutionException - When an error occurs during the request execution, typically a network error, an error from the GraphQL server or if the server response can't be parsed

exec

public reactor.core.publisher.Flux<Subscription> exec(String queryResponseDef,
 Object... paramsAndValues)
                                               throws GraphQLRequestExecutionException,
GraphQLRequestPreparationException

This method takes a subscription full request definition, and executes it in reactive mode against the GraphQL server. It may only return one subscription's field.
It offers a logging of the call (if in debug mode), or of the call and its parameters (if in trace mode).
Here is a sample on how to use it:

Parameters:

queryResponseDef - The response definition of the query, in the native GraphQL format (see here above). It must ommit the query/mutation/subscription keyword, and start by the first { that follows.It may contain directives, as explained in the GraphQL specs.

paramsAndValues - This parameter contains all the name and values for the Bind Variables defined in the objectResponse parameter, that must be sent to the server. Optional parameter may not have a value. They will be ignored and not sent to the server. Mandatory parameter must be provided in this argument.
This parameter contains an even number of parameters: it must be a series of name and values : (paramName1, paramValue1, paramName2, paramValue2...)

Returns:

The SubscriptionClient that allows the caller to act on the subscribed subscription.

Throws:

GraphQLRequestPreparationException - When an error occurs during the request preparation, typically when building the ObjectResponse

GraphQLRequestExecutionException - When an error occurs during the request execution, typically a network error, an error from the GraphQL server or if the server response can't be parsed

execWithBindValues

public reactor.core.publisher.Flux<Subscription> execWithBindValues(ObjectResponse objectResponse,
 Map<String,Object> parameters)
                                                             throws GraphQLRequestExecutionException

This method takes a subscription full request definition, and executes it in reactive mode against the GraphQL server. It may only return one subscription's field.
It offers a logging of the call (if in debug mode), or of the call and its parameters (if in trace mode).
Here is a sample on how to use it:

Parameters:

objectResponse - The definition of the response format, that describes what the GraphQL server is expected to return
Note: the ObjectResponse type of this parameter is defined for backward compatibility. In new implementations, the expected type is the generated GraphQLRequestForum POJO, as returned by the getGraphQLRequest(java.lang.String) method or one of the getXxxxGraphQLRequest(String) methods.

parameters - The list of values, for the bind variables defined in the query. If there is no bind variable in the defined Query, this argument may be null or an empty Map

Returns:

The SubscriptionClient that allows the caller to act on the subscribed subscription.

Throws:

GraphQLRequestExecutionException - When an error occurs during the request execution, typically a network error, an error from the GraphQL server or if the server response can't be parsed

exec

public reactor.core.publisher.Flux<Subscription> exec(ObjectResponse objectResponse,
 Object... paramsAndValues)
                                               throws GraphQLRequestExecutionException

This method takes a subscription full request definition, and executes it in reactive mode against the GraphQL server. It may only return one subscription's field.
It offers a logging of the call (if in debug mode), or of the call and its parameters (if in trace mode).
Here is a sample on how to use it:

Parameters:

objectResponse - The definition of the response format, that describes what the GraphQL server is expected to return
Note: the ObjectResponse type of this parameter is defined for backward compatibility. In new implementations, the expected type is the generated GraphQLRequestForum POJO, as returned by the getGraphQLRequest(java.lang.String) method or one of the getXxxxGraphQLRequest(String) methods.

paramsAndValues - This parameter contains all the name and values for the Bind Variables defined in the objectResponse parameter, that must be sent to the server. Optional parameter may not have a value. They will be ignored and not sent to the server. Mandatory parameter must be provided in this argument.
This parameter contains an even number of parameters: it must be a series of name and values : (paramName1, paramValue1, paramName2, paramValue2...)

Returns:

The SubscriptionClient that allows the caller to act on the subscribed subscription.

Throws:

GraphQLRequestExecutionException - When an error occurs during the request execution, typically a network error, an error from the GraphQL server or if the server response can't be parsed

getResponseBuilder

public Builder getResponseBuilder()
                           throws GraphQLRequestPreparationException

Get the Builder for a full request, as expected by the exec and execWithBindValues methods.

Returns:

Throws:

GraphQLRequestPreparationException

getGraphQLRequest

public GraphQLReactiveRequestForum getGraphQLRequest(String fullRequest)
                                              throws GraphQLRequestPreparationException

Get the GraphQLRequestForum for full request. For instance:

 GraphQLRequestForum request = new GraphQLRequestForum(fullRequest);
 

Parameters:

fullRequest - The full GraphQL request, as specified in the GraphQL specification

Returns:

Throws:

GraphQLRequestPreparationException

subscribeToNewPostWithBindValues

public reactor.core.publisher.Flux<Optional<Post>> subscribeToNewPostWithBindValues(String queryResponseDef,
 String boardName,
 Map<String,Object> parameters)
                                                                             throws GraphQLRequestExecutionException,
GraphQLRequestPreparationException

This method registers a subscription, by executing a direct partial subscribeToNewPost subscription against the GraphQL server. This subscription is one of the fields defined in the GraphQL subscription object. The queryResponseDef contains the part of the subscription that is after the subscription name (see the sample below), for instance "{id name}" if you want these two fields to be sent in the notifications you'll receive for this subscription.

Parameters:

queryResponseDef - The response definition of the subscription, in the native GraphQL format (see here above)

boardName - Parameter for the subscribeToNewPost field of Subscription, as defined in the GraphQL schema

parameters - The list of values, for the bind variables defined in the subscription. If there is no bind variable in the defined subscription, this argument may be null or an empty Map

Throws:

GraphQLRequestPreparationException - When an error occurs during the request preparation, typically when building the ObjectResponse

GraphQLRequestExecutionException - When an error occurs during the request execution, typically a network error, an error from the GraphQL server or if the server response can't be parsed

subscribeToNewPost

public reactor.core.publisher.Flux<Optional<Post>> subscribeToNewPost(String queryResponseDef,
 String boardName,
 Object... paramsAndValues)
                                                               throws GraphQLRequestExecutionException,
GraphQLRequestPreparationException

This method registers a subscription, by executing a direct partial request against the GraphQL server. This subscription is one of the fields defined in the GraphQL subscription object. The queryResponseDef contains the part of the subscription that is after the subscription name (see the sample below), for instance "{id name}" if you want these two fields to be sent in the notifications you'll receive for this subscription.
You must also provide a callback instance of the SubscriptionCallback, and the parameter for the subscription as parameter for this method. For instance, if the subscription subscribeToNewPost has one parameter boardName (as defined in the GraphQL schema):

Parameters:

queryResponseDef - The response definition of the subscription, in the native GraphQL format (see here above)

boardName - Parameter for the subscribeToNewPost field of Subscription, as defined in the GraphQL schema

parameters - The list of values, for the bind variables defined in the subscription. If there is no bind variable in the defined subscription, this argument may be null or an empty Map

Throws:

GraphQLRequestPreparationException - When an error occurs during the request preparation, typically when building the ObjectResponse

GraphQLRequestExecutionException - When an error occurs during the request execution, typically a network error, an error from the GraphQL server or if the server response can't be parsed

subscribeToNewPostWithBindValues

public reactor.core.publisher.Flux<Optional<Post>> subscribeToNewPostWithBindValues(ObjectResponse objectResponse,
 String boardName,
 Map<String,Object> parameters)
                                                                             throws GraphQLRequestExecutionException

This method registers a subscription, by executing a direct partial request against the GraphQL server. This subscription is one of the fields defined in the GraphQL subscription object. The queryResponseDef contains the part of the subscription that is after the subscription name (see the sample below), for instance "{id name}" if you want these two fields to be sent in the notifications you'll receive for this subscription.
You must also provide a callback instance of the SubscriptionCallback, and the parameter for the subscription as parameter for this method. For instance, if the subscription subscribeToNewPost has one parameter boardName (as defined in the GraphQL schema):

Parameters:

objectResponse - The definition of the response format, that describes what the GraphQL server is expected to return
Note: the ObjectResponse type of this parameter is defined for backward compatibility. In new implementations, the expected type is the generated GraphQLRequestForum POJO, as returned by the getSubscribeToNewPostGraphQLRequest(java.lang.String) method.

boardName - Parameter for the subscribeToNewPost field of Subscription, as defined in the GraphQL schema

parameters - The list of values, for the bind variables defined in the subscription. If there is no bind variable in the defined Query, this argument may be null or an empty Map

Throws:

GraphQLRequestExecutionException - When an error occurs during the request execution, typically a network error, an error from the GraphQL server or if the server response can't be parsed

subscribeToNewPost

public reactor.core.publisher.Flux<Optional<Post>> subscribeToNewPost(ObjectResponse objectResponse,
 String boardName,
 Object... paramsAndValues)
                                                               throws GraphQLRequestExecutionException

This method registers a subscription, by executing a direct partial request against the GraphQL server. This subscription is one of the fields defined in the GraphQL subscription object. The queryResponseDef contains the part of the subscription that is after the subscription name (see the sample below), for instance "{id name}" if you want these two fields to be sent in the notifications you'll receive for this subscription.
You must also provide a callback instance of the SubscriptionCallback, and the parameter for the subscription as parameter for this method. For instance, if the subscription subscribeToNewPost has one parameter boardName (as defined in the GraphQL schema):

Parameters:

objectResponse - The definition of the response format, that describes what the GraphQL server is expected to return
Note: the ObjectResponse type of this parameter is defined for backward compatibility. In new implementations, the expected type is the generated GraphQLRequestForum POJO, as returned by the getSubscribeToNewPostGraphQLRequest(java.lang.String) method.

boardName - Parameter for the subscribeToNewPost field of Subscription, as defined in the GraphQL schema

paramsAndValues - This parameter contains all the name and values for the Bind Variables defined in the objectResponse parameter, that must be sent to the server. Optional parameter may not have a value. They will be ignored and not sent to the server. Mandatory parameter must be provided in this argument.
This parameter contains an even number of parameters: it must be a series of name and values : (paramName1, paramValue1, paramName2, paramValue2...)

Throws:

GraphQLRequestExecutionException - When an error occurs during the request execution, typically a network error, an error from the GraphQL server or if the server response can't be parsed

getSubscribeToNewPostResponseBuilder

public Builder getSubscribeToNewPostResponseBuilder()
                                             throws GraphQLRequestPreparationException

Get the Builder for the Post, as expected by the subscribeToNewPost subscription.

Returns:

Throws:

GraphQLRequestPreparationException

getSubscribeToNewPostGraphQLRequest

public GraphQLReactiveRequestForum getSubscribeToNewPostGraphQLRequest(String partialRequest)
                                                                throws GraphQLRequestPreparationException

Get the GraphQLRequestForum for the subscribeToNewPost REACTIVE_EXECUTOR, created with the given Partial request.

Parameters:

partialRequest - The Partial GraphQL request, as explained in the plugin client documentation

Returns:

Throws:

GraphQLRequestPreparationException