Package csw.command.client.handlers

Class CommandServiceRequestHandler

java.lang.Object
msocket.http.post.HttpPostHandler<CommandServiceRequest>
csw.command.client.handlers.CommandServiceRequestHandler
All Implemented Interfaces:
io.bullet.borer.compat.AkkaHttpCompat, msocket.api.codecs.BasicCodecs, msocket.http.post.ServerHttpCodecs
public class CommandServiceRequestHandler extends msocket.http.post.HttpPostHandler<CommandServiceRequest> implements msocket.http.post.ServerHttpCodecs

  • Constructor Summary

    Constructors
    Constructor
    Description
    CommandServiceRequestHandler(csw.command.api.scaladsl.CommandService commandService, csw.aas.http.SecurityDirectives securityDirectives, scala.Option<Prefix> destinationPrefix, CommandRoles commandRoles)
     

  • Method Summary

    Modifier and Type
    Method
    Description
    io.bullet.borer.Codec<akka.Done>
    doneCodec()
     
    scala.Function1<akka.http.scaladsl.server.RequestContext,scala.concurrent.Future<akka.http.scaladsl.server.RouteResult>>
    handle(CommandServiceRequest request)
     
    akka.http.scaladsl.common.JsonEntityStreamingSupport
    jsonStreamingSupport()
     
    io.bullet.borer.Codec<akka.util.Timeout>
    timeoutInSecondsCodec()
     

    Methods inherited from class java.lang.Object

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

    Methods inherited from interface io.bullet.borer.compat.AkkaHttpCompat

    borerCborMarshaller, borerCborMarshaller$default$1, borerCborMarshaller$default$2, borerCborUnmarshaller, borerCborUnmarshaller$default$1, borerCborUnmarshaller$default$2, borerFromEntityUnmarshaller, borerFromMessageUnmarshaller, borerJsonMarshaller, borerJsonMarshaller$default$1, borerJsonMarshaller$default$2, borerJsonStreamFromEntityUnmarshaller, borerJsonStreamFromMessageUnmarshaller, borerJsonStreamToResponseMarshaller, borerJsonUnmarshaller, borerJsonUnmarshaller$default$1, borerJsonUnmarshaller$default$2, borerMarshaller, borerMarshaller$default$1, borerMarshaller$default$2, borerMarshaller$default$3, borerMarshaller$default$4, borerMarshaller$default$5, borerStreamMarshaller, borerStreamUnmarshaller, borerToEntityMarshaller, borerToResponseMarshaller, borerUnmarshaller, borerUnmarshaller$default$1, borerUnmarshaller$default$2, borerUnmarshaller$default$3, borerUnmarshaller$default$4

    Methods inherited from interface msocket.api.codecs.BasicCodecs

    eitherCodec

    Methods inherited from interface msocket.http.post.ServerHttpCodecs

    borerJsonStreamToEntityMarshaller, msocket$http$post$ServerHttpCodecs$_setter_$jsonStreamingSupport_$eq

  • Constructor Details

    • CommandServiceRequestHandler

      public CommandServiceRequestHandler(csw.command.api.scaladsl.CommandService commandService, csw.aas.http.SecurityDirectives securityDirectives, scala.Option<Prefix> destinationPrefix, CommandRoles commandRoles)

  • Method Details

    • jsonStreamingSupport

      public akka.http.scaladsl.common.JsonEntityStreamingSupport jsonStreamingSupport()
      Specified by:
      jsonStreamingSupport in interface msocket.http.post.ServerHttpCodecs

    • doneCodec

      public io.bullet.borer.Codec<akka.Done> doneCodec()
      Specified by:
      doneCodec in interface msocket.api.codecs.BasicCodecs

    • timeoutInSecondsCodec

      public io.bullet.borer.Codec<akka.util.Timeout> timeoutInSecondsCodec()
      Specified by:
      timeoutInSecondsCodec in interface msocket.api.codecs.BasicCodecs

    • handle

      public scala.Function1<akka.http.scaladsl.server.RequestContext,scala.concurrent.Future<akka.http.scaladsl.server.RouteResult>> handle(CommandServiceRequest request)
      Specified by:
      handle in class msocket.http.post.HttpPostHandler<CommandServiceRequest>