org.mule.modules.jde.internal.operation

Class PollEventsOperations

java.lang.Object

org.mule.modules.jde.internal.operation.PollEventsOperations

public class PollEventsOperations
extends Object

Operations to poll outbound/interoperability events from JDE via the Atina Microservice.

Since:

3.0.0

Constructor Summary

Constructors

Constructor and Description
PollEventsOperations()

Method Summary

Modifier and Type	Method and Description
org.mule.runtime.extension.api.runtime.operation.Result<Map<String,Serializable>,Void>	pollEvents(JDEAtinaConfiguration configuration, JDEAtinaConnection connection, String operation, Map<String,Object> inputParameters) Polls JDE event queues (e.g., interoperability/CM events) through the Atina Microservice.

Methods inherited from class java.lang.Object

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

Constructor Detail

PollEventsOperations

public PollEventsOperations()

Method Detail

pollEvents

@DisplayName(value="Poll Events")
 @Summary(value="Reads MBSFN Outbound events from JDE Server")
 @OutputResolver(output=PollEventsOutputEntityMetadataResolver.class)
 @Throws(value=PollEventsProvider.class)
public org.mule.runtime.extension.api.runtime.operation.Result<Map<String,Serializable>,Void> pollEvents(@Config
                                                                                                                                                                                                                                                                                                                         JDEAtinaConfiguration configuration,
                                                                                                                                                                                                                                                                                                                         @Connection
                                                                                                                                                                                                                                                                                                                         JDEAtinaConnection connection,
                                                                                                                                                                                                                                                                                                                         @MetadataKeyId(value=PollEventsNameKeysMetadataResolver.class) @Example(value="Capture Event Transactions")
                                                                                                                                                                                                                                                                                                                         String operation,
                                                                                                                                                                                                                                                                                                                         @Content @TypeResolver(value=PollEventsInputEntityMetadataResolver.class)
                                                                                                                                                                                                                                                                                                                         Map<String,Object> inputParameters)

Polls JDE event queues (e.g., interoperability/CM events) through the Atina Microservice.

Behavior:

• Delegates to JDEAtinaConnection.invokeOperation(String, String, Map) using the operation key resolved by PollEventsNameKeysMetadataResolver.
• Input structure (e.g., transaction code, batch number, quantity to read, lock/update flags) is defined by PollEventsInputEntityMetadataResolver.

Output:

• A Map<String, Serializable> with the polled events and related metadata, described by PollEventsOutputEntityMetadataResolver.

Errors:

• On failure, a ModuleException with HierarchalErrorType.ERROR_POLL_EVENTS is thrown (declared by the error provider).

Parameters:

configuration - The configured JDE Atina connector settings.

connection - The active Atina/JDE connection.

operation - Logical operation key (e.g., "Capture Event Transactions").

inputParameters - Parameters required to perform the poll (see input metadata).

Returns:

A Result containing the polled events and metadata.