Package org.openidentityplatform.openig.mq

Class MQ_Kafka

java.lang.Object

org.openidentityplatform.openig.mq.MQ_Kafka

All Implemented Interfaces:

org.forgerock.http.Handler

public class MQ_Kafka
extends Object
implements org.forgerock.http.Handler

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	MQ_Kafka.Heaplet	Creates and initializes a client handler in a heap environment.

Constructor Summary

Constructors

Constructor	Description
MQ_Kafka()

Method Summary

Modifier and Type	Method	Description
org.forgerock.util.promise.Promise<org.forgerock.http.protocol.Response,org.forgerock.util.promise.NeverThrowsException>	handle(org.forgerock.services.context.Context context, org.forgerock.http.protocol.Request request)

Methods inherited from class java.lang.Object

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

Constructor Detail

MQ_Kafka

public MQ_Kafka()

Method Detail

handle

public org.forgerock.util.promise.Promise<org.forgerock.http.protocol.Response,org.forgerock.util.promise.NeverThrowsException> handle(org.forgerock.services.context.Context context,
                                                                                                                                             org.forgerock.http.protocol.Request request)

Specified by:

handle in interface org.forgerock.http.Handler