Package csw.command.client.handlers

Class 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

      All Methods Instance Methods Concrete Methods 
      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 Detail

      • CommandServiceRequestHandler

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

    • Method Detail

      • 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>