Announcement Announcement Module
Collapse
No announcement yet.
creating a tap does not work Page Title Module
Move Remove Collapse
X
Conversation Detail Module
Collapse
  • Filter
  • Time
  • Show
Clear All
new posts

  • creating a tap does not work

    $ curl -d "http --port=8010 | filter | file" http://localhost:8080/streams/test1

    Works.

    $ curl -d "[email protected] | log" http://localhost:8080/streams/test11

    Code:
    16.06.2013 14:41:40 org.apache.catalina.core.StandardWrapperValve invoke
    SCHWERWIEGEND: Servlet.service() for servlet [streams] in context with path [/] threw exception
    org.springframework.integration.MessageHandlingException: java.lang.IllegalArgumentException: No tap channel exists for 'test1.filter.0'. A tap is onl
    y valid for a registered inbound channel.
            at org.springframework.integration.handler.MethodInvokingMessageProcessor.processMessage(MethodInvokingMessageProcessor.java:76)
            at org.springframework.integration.handler.ServiceActivatingHandler.handleRequestMessage(ServiceActivatingHandler.java:67)
            at org.springframework.integration.handler.AbstractReplyProducingMessageHandler.handleMessageInternal(AbstractReplyProducingMessageHandler.jav
    a:137)
            at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:73)
            at org.springframework.integration.dispatcher.UnicastingDispatcher.doDispatch(UnicastingDispatcher.java:115)
            at org.springframework.integration.dispatcher.UnicastingDispatcher.dispatch(UnicastingDispatcher.java:102)
            at org.springframework.integration.channel.AbstractSubscribableChannel.doSend(AbstractSubscribableChannel.java:77)
            at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:178)
            at org.springframework.integration.channel.AbstractMessageChannel.send(AbstractMessageChannel.java:149)
            at org.springframework.xd.dirt.stream.DefaultStreamDeployer.deployStream(DefaultStreamDeployer.java:54)
            at org.springframework.xd.dirt.stream.StreamServer$XdServlet.service(StreamServer.java:174)
            at javax.servlet.http.HttpServlet.service(HttpServlet.java:728)
            at org.apache.catalina.core.ApplicationFilterChain.internalDoFilter(ApplicationFilterChain.java:305)
            at org.apache.catalina.core.ApplicationFilterChain.doFilter(ApplicationFilterChain.java:210)
            at org.apache.catalina.core.StandardWrapperValve.invoke(StandardWrapperValve.java:222)
            at org.apache.catalina.core.StandardContextValve.invoke(StandardContextValve.java:123)
            at org.apache.catalina.authenticator.AuthenticatorBase.invoke(AuthenticatorBase.java:472)
            at org.apache.catalina.core.StandardHostValve.invoke(StandardHostValve.java:171)
            at org.apache.catalina.valves.ErrorReportValve.invoke(ErrorReportValve.java:99)
            at org.apache.catalina.core.StandardEngineValve.invoke(StandardEngineValve.java:118)
            at org.apache.catalina.connector.CoyoteAdapter.service(CoyoteAdapter.java:407)
            at org.apache.coyote.http11.AbstractHttp11Processor.process(AbstractHttp11Processor.java:1004)
            at org.apache.coyote.AbstractProtocol$AbstractConnectionHandler.process(AbstractProtocol.java:589)
            at org.apache.tomcat.util.net.JIoEndpoint$SocketProcessor.run(JIoEndpoint.java:310)
            at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:885)
            at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:907)
            at java.lang.Thread.run(Thread.java:619)
    Caused by: java.lang.IllegalArgumentException: No tap channel exists for 'test1.filter.0'. A tap is only valid for a registered inbound channel.
            at org.springframework.integration.x.channel.registry.LocalChannelRegistry.tap(LocalChannelRegistry.java:114)
            at org.springframework.xd.dirt.stream.Tap.afterPropertiesSet(Tap.java:53)
            at org.springframework.xd.dirt.plugins.StreamPlugin.createTap(StreamPlugin.java:62)
            at org.springframework.xd.dirt.plugins.StreamPlugin.processModule(StreamPlugin.java:51)
            at org.springframework.xd.dirt.module.ModuleDeployer.processModule(ModuleDeployer.java:151)
            at org.springframework.xd.dirt.module.ModuleDeployer.deployModule(ModuleDeployer.java:119)
            at org.springframework.xd.dirt.module.ModuleDeployer.handleMessageInternal(ModuleDeployer.java:108)
            at org.springframework.integration.handler.AbstractMessageHandler.handleMessage(AbstractMessageHandler.java:73)
            at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
            at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:39)
            at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
            at java.lang.reflect.Method.invoke(Method.java:597)
            at org.springframework.expression.spel.support.ReflectiveMethodExecutor.execute(ReflectiveMethodExecutor.java:69)
            at org.springframework.expression.spel.ast.MethodReference$MethodValueRef.getValue(MethodReference.java:73)
            at org.springframework.expression.spel.ast.CompoundExpression.getValueInternal(CompoundExpression.java:82)
            at org.springframework.expression.spel.ast.SpelNodeImpl.getTypedValue(SpelNodeImpl.java:102)
            at org.springframework.expression.spel.standard.SpelExpression.getValue(SpelExpression.java:103)
            at org.springframework.integration.util.AbstractExpressionEvaluator.evaluateExpression(AbstractExpressionEvaluator.java:126)
            at org.springframework.integration.util.MessagingMethodInvokerHelper.processInternal(MessagingMethodInvokerHelper.java:230)
            at org.springframework.integration.util.MessagingMethodInvokerHelper.process(MessagingMethodInvokerHelper.java:129)
            at org.springframework.integration.handler.MethodInvokingMessageProcessor.processMessage(MethodInvokingMessageProcessor.java:73)
            ... 26 more
    What's wrong here?

    Thank you
    Last edited by spgmx; Jun 16th, 2013, 08:14 AM.

  • #2
    While this does not work:

    $ curl -d "[email protected] | log" http://localhost:8080/streams/test11

    This works:

    $ curl -d "tap@test1 | log" http://localhost:8080/streams/test11

    Bug?

    Comment


    • #3
      Well, the @ was the problem... bug in docs. This works:

      $ curl -d "tap test1.filter | log" http://localhost:8080/streams/test11

      Comment


      • #4
        I would try the following.

        curl -d "tap@filter | log" http://localhost:8080/streams/test11

        This should create a tap on the filter module on the test11 stream.

        Comment

        Working...
        X