在 Mule ESB 中使用 twitter 用户流时出错

Question

我正在运行将 twitter 作为流式入站端点捕获所有用户 sream 或用户事件的过程。

我有时会收到以下错误

WARN 2014-11-19 11:52:05,716 [Twitter4J Async Dispatcher[0]] org.mule.context.notification.ServerNotificationManager：ServerNotificationManager 处置后通知未入队：PipelineMessageNotification{action=pipeline process start, resourceId=CaptureTweets , serverId=null, 时间戳=1416378125716} WARN 2014-11-19 11:52:05,736 [Twitter4J Async Dispatcher[0]] org.mule.context.notification.ServerNotificationManager：ServerNotificationManager 处置后通知未入队：PipelineMessageNotification{action=pipeline process complete，resourceId=CaptureTweets，serverId=空，时间戳=1416378125736} 错误 2014-11-19 11:52:05,736 [Twitter4J Async Dispatcher[0]] org.mule.twitter.adapters.TwitterConnectorConnectionIdentifierAdapter：org.mule.api.MessagingException：无法处理事件，因为“CaptureTweets”已停止（org.mule .api.lifecycle.LifecycleException）。消息负载的类型：UserEvent org.apache.commons.lang.UnhandledException：org.mule.api.MessagingException：无法处理事件，因为“CaptureTweets”已停止（org.mule.api.lifecycle.LifecycleException）。消息负载的类型：UserEvent 在 org.mule.twitter.TwitterConnector$SoftCallback.process(TwitterConnector.java:1270) 在 org.mule.twitter.TwitterConnector$1.onStatus(TwitterConnector.java:893) 在 twitter4j.StatusStreamImpl.onStatus(StatusStreamImpl.java:75) 在 twitter4j.StatusStreamBase$1.run(StatusStreamBase.java:114) 在 twitter4j.internal.async.ExecuteThread.run(DispatcherImpl.java:116) 原因：org.mule.api.MessagingException：无法处理事件，因为“CaptureTweets”已停止（org.mule.api.lifecycle.LifecycleException）。消息负载的类型：UserEvent 在 org.mule.execution.ExceptionToMessagingExceptionExecutionInterceptor.execute(ExceptionToMessagingExceptionExecutionInterceptor.java:32) 在 org.mule.execution.MessageProcessorNotificationExecutionInterceptor.execute(MessageProcessorNotificationExecutionInterceptor.java:58) 在 org.mule.execution.MessageProcessorExecutionTemplate.execute（MessageProcessorExecutionTemplate.java:44） 在 org.mule.processor.AbstractInterceptingMessageProcessorBase.processNext（AbstractInterceptingMessageProcessorBase.java:102） 在 org.mule.construct.AbstractPipeline$1.process(AbstractPipeline.java:109) 在 org.mule.execution.ExceptionToMessagingExceptionExecutionInterceptor.execute(ExceptionToMessagingExceptionExecutionInterceptor.java:24) 在 org.mule.execution.MessageProcessorNotificationExecutionInterceptor.execute(MessageProcessorNotificationExecutionInterceptor.java:58) 在 org.mule.execution.MessageProcessorExecutionTemplate.execute（MessageProcessorExecutionTemplate.java:44） 在 org.mule.processor.chain.DefaultMessageProcessorChain.doProcess（DefaultMessageProcessorChain.java:94） 在 org.mule.processor.chain.AbstractMessageProcessorChain.process（AbstractMessageProcessorChain.java:67） 在 org.mule.processor.chain.InterceptingChainLifecycleWrapper.doProcess（InterceptingChainLifecycleWrapper.java:50） 在 org.mule.processor.chain.AbstractMessageProcessorChain.process（AbstractMessageProcessorChain.java:67） 在 org.mule.processor.chain.InterceptingChainLifecycleWrapper.access$001（InterceptingChainLifecycleWrapper.java:22） 在 org.mule.processor.chain.InterceptingChainLifecycleWrapper$1.process(InterceptingChainLifecycleWrapper.java:66) 在 org.mule.execution.ExceptionToMessagingExceptionExecutionInterceptor.execute(ExceptionToMessagingExceptionExecutionInterceptor.java:24) 在 org.mule.execution.MessageProcessorNotificationExecutionInterceptor.execute(MessageProcessorNotificationExecutionInterceptor.java:58) 在 org.mule.execution.MessageProcessorExecutionTemplate.execute（MessageProcessorExecutionTemplate.java:44） 在 org.mule.processor.chain.InterceptingChainLifecycleWrapper.process（InterceptingChainLifecycleWrapper.java:61） 在 org.mule.construct.AbstractPipeline$3.process(AbstractPipeline.java:207) 在 org.mule.security.oauth.processor.AbstractListeningMessageProcessor.processEvent（AbstractListeningMessageProcessor.java:150） 在 org.mule.security.oauth.processor.AbstractListeningMessageProcessor.process(AbstractListeningMessageProcessor.java:76) 在 org.mule.twitter.TwitterConnector$SoftCallback.process(TwitterConnector.java:1268) ... 4 更多 原因：org.mule.api.lifecycle.LifecycleException：无法处理事件，因为“CaptureTweets”已停止 在 org.mule.construct.AbstractPipeline$ProcessIfPipelineStartedMessageProcessor.handleUnaccepted(AbstractPipeline.java:400) 在 org.mule.processor.AbstractFilteringMessageProcessor.process（AbstractFilteringMessageProcessor.java:44） 在 org.mule.execution.ExceptionToMessagingExceptionExecutionInterceptor.execute(ExceptionToMessagingExceptionExecutionInterceptor.java:24) ... 25 更多

不确定错误，需要更多信息。

Answer 1

您需要有<json:object-to-json-transformer> 才能转换 Twitter 数据
您能否请检查此链接以了解将 Mule 与 Twitter 连接的想法：- http://www.whishworks.com/blog/integration-with-twitter-using-mule-esb/