仅接收器应用程序停止-通道关闭(smfclient 2)无错误

Question

我们正在使用spring cloud stream solace绑定器开发一个原型。当我的应用程序定义了源和接收器，并定期发布消息，而接收器以大写字母打印消息时-一切都按预期工作。但是，当我们尝试运行仅具有接收器配置的应用程序时，应用程序在成功连接到代理后停止。下面提供了日志。

spring:
  cloud:
    stream:
     bindings:
        fjp-greetings-in:
          destination: <TOPIC_NAME_HERE>
          group: <QUEUE_NAME_HERE>
solace:
  java:
    host: tcp://<HOST_NAME_HERE>:<PORT_HERE>
    msgVpn: <VPN_NAME_HERE>
    clientUsername: <USERNAME_HERE>
    clientPassword: <PWD_HERE>
    connectRetries: -1
    reconnectRetries: -1

public interface GreetingsStreams {
    String INPUT = "greetings-in";
    @Input(INPUT)
    SubscribableChannel inboundGreetings();

@SpringBootApplication
@EnableBinding(GreetingsStreams.class)
@Slf4j
public class PocSpringcloudstreamApplication {

    public static void main(String[] args) {
        SpringApplication.run(PocSpringcloudstreamApplication.class, args);
    }

    @StreamListener(GreetingsStreams.INPUT)
    public void handle(String msg) {
        log.info("Received Message: " + msg.toUpperCase());
    }

以下是在STS中尝试从spring boot仪表板运行应用程序时来自控制台的日志-

2019-08-23 12:11:24.906 DEBUG 8956 --- [1_ReactorThread] c.s.jcsmp.impl.flow.FlowHandleImpl       : Flow 76: Starting sub ad timer: scheduled new timer in 1000
2019-08-23 12:11:24.920 DEBUG 8956 --- [1_ReactorThread] c.s.jcsmp.impl.flow.FlowHandleImpl       : Flow 76: Enqueue to delivery: msg=1, dest=<TOPIC_NAME_HERE>
2019-08-23 12:11:24.928 DEBUG 8956 --- [1_ReactorThread] c.s.jcsmp.impl.ReconnectFreqManager      : Timer expiry: checking reconnect counter.
2019-08-23 12:11:24.928 DEBUG 8956 --- [1_ReactorThread] c.s.jcsmp.impl.ReconnectFreqManager      : Reconnect frequency OK: count=1
2019-08-23 12:11:24.929 DEBUG 8956 --- [1_ReactorThread] c.s.j.impl.client.ClientRequestResponse  : Stopping request timer (SMP-SmpRequest)
2019-08-23 12:11:24.929 DEBUG 8956 --- [           main] c.s.j.protocol.impl.TcpClientChannel     : Error Response (400) - Subscription Already Exists - Queue '<QUEUE_NAME_HERE>' - Topic '<TOPIC_NAME_HERE>'
2019-08-23 12:11:24.930  WARN 8956 --- [           main] c.s.s.c.s.b.p.SolaceQueueProvisioner     : Queue <QUEUE_NAME_HERE> is already subscribed to topic <TOPIC_NAME_HERE>, SUBSCRIPTION_ALREADY_PRESENT error will be ignored...
2019-08-23 12:11:24.930  INFO 8956 --- [           main] c.s.s.c.s.b.i.JCSMPInboundChannelAdapter : started com.solace.spring.cloud.stream.binder.inbound.JCSMPInboundChannelAdapter@746b18fd
2019-08-23 12:11:24.958  INFO 8956 --- [           main] f.p.s.PocSpringcloudstreamApplication : Started PocSpringcloudstreamApplication in 37.017 seconds (JVM running for 40.443)
2019-08-23 12:11:24.966 DEBUG 8956 --- [       Thread-6] c.s.jcsmp.impl.flow.SubFlowManagerImpl   : SubFlowManagerImpl closing... close 1 flows
2019-08-23 12:11:24.967 DEBUG 8956 --- [       Thread-6] c.s.jcsmp.impl.flow.FlowHandleImpl       : Flow 76: pauseFlowInternally=false
2019-08-23 12:11:24.967 DEBUG 8956 --- [       Thread-6] c.s.jcsmp.impl.flow.FlowHandleImpl       : Flow 76: _startState=STOPPED
2019-08-23 12:11:24.967 DEBUG 8956 --- [       Thread-6] c.s.jcsmp.impl.flow.FlowHandleImpl       : Flow 76: Clear AD timer
2019-08-23 12:11:24.985 DEBUG 8956 --- [       Thread-6] c.s.jcsmp.impl.flow.FlowHandleImpl       : Flow 76: Clear AD timer
2019-08-23 12:11:24.985 DEBUG 8956 --- [       Thread-6] c.s.jcsmp.impl.flow.FlowHandleImpl       : Flow 76: window size 0 due to startState=STOPPED
2019-08-23 12:11:24.985 DEBUG 8956 --- [       Thread-6] c.s.jcsmp.impl.flow.FlowHandleImpl       : Flow 76: getWindowSize()=0
2019-08-23 12:11:24.985 DEBUG 8956 --- [       Thread-6] c.s.jcsmp.impl.flow.FlowSmfUtil          : tpCreateAck: flow_d: 76, TpMsgId: 1, windowSz: 0
2019-08-23 12:11:24.985 DEBUG 8956 --- [       Thread-6] c.s.jcsmp.impl.flow.FlowHandleImpl       : tpCreateAck: flow_d: 76, tt_lastInOrderTpMsg: 1, tt_windowSz: 0
2019-08-23 12:11:24.985 DEBUG 8956 --- [       Thread-6] c.s.j.impl.queues.UnackedMessageList2    : UNACKLIST-ack>>> reason=flow-closing flow=76
2019-08-23 12:11:24.985 DEBUG 8956 --- [       Thread-6] c.s.j.protocol.impl.TcpClientChannel     : Client channel (smfclient 2) stopping KA timer
2019-08-23 12:11:24.985 DEBUG 8956 --- [       Thread-6] c.s.jcsmp.protocol.impl.TcpChannel       : Canceled KA timer
2019-08-23 12:11:24.986  INFO 8956 --- [       Thread-6] c.s.j.protocol.impl.TcpClientChannel     : Channel Closed (smfclient 2)
2019-08-23 12:11:24.986 DEBUG 8956 --- [       Thread-6] c.s.jcsmp.protocol.smf.SimpleSmfClient   : Local addr: xxxx   Remote addr: xxxx(smfclient 2) Closing socket
2019-08-23 12:11:24.987 DEBUG 8956 --- [       Thread-6] c.s.jcsmp.impl.JCSMPBasicSession         : JCSMPSession[xxxx@tcp://xxxx] (0001)closed
2019-08-23 12:11:24.988  INFO 8956 --- [       Thread-6] c.s.s.c.s.b.i.JCSMPInboundChannelAdapter : Stopping consumer flow from queue <QUEUE_NAME_HERE> <inbound adapter ID: 8def919b-8367-4922-8451-34e0865c5d0c>
2019-08-23 12:11:24.989 DEBUG 8956 --- [       Thread-6] c.s.jcsmp.impl.JCSMPBasicSession         : waiting for session reconnect done, sessionID= JCSMPSession[xxxx@xxxx:xxxx] (0001), called from close
2019-08-23 12:11:24.989  INFO 8956 --- [       Thread-6] c.s.s.c.s.b.i.JCSMPInboundChannelAdapter : stopped com.solace.spring.cloud.stream.binder.inbound.JCSMPInboundChannelAdapter@746b18fd
2019-08-23 12:11:24.989  INFO 8956 --- [       Thread-6] o.s.c.stream.binder.BinderErrorChannel   : Channel 'application.<QUEUE_NAME_HERE>.errors' has 1 subscriber(s).
2019-08-23 12:11:24.989  INFO 8956 --- [       Thread-6] o.s.c.stream.binder.BinderErrorChannel   : Channel 'application.<QUEUE_NAME_HERE>.errors' has 0 subscriber(s).
2019-08-23 12:11:24.990  INFO 8956 --- [       Thread-6] o.s.i.endpoint.EventDrivenConsumer       : Removing {logging-channel-adapter:_org.springframework.integration.errorLogger} as a subscriber to the 'errorChannel' channel
2019-08-23 12:11:24.990  INFO 8956 --- [       Thread-6] o.s.i.channel.PublishSubscribeChannel    : Channel 'application.errorChannel' has 0 subscriber(s).
2019-08-23 12:11:24.990  INFO 8956 --- [       Thread-6] o.s.i.endpoint.EventDrivenConsumer       : stopped _org.springframework.integration.errorLogger
2019-08-23 12:11:24.991  INFO 8956 --- [       Thread-6] o.s.s.c.ThreadPoolTaskScheduler          : Shutting down ExecutorService 'taskScheduler'
2019-08-23 12:11:24.999  INFO 8956 --- [       Thread-6] o.s.i.monitor.IntegrationMBeanExporter   : Summary on shutdown: <QUEUE_NAME_HERE>.errors
2019-08-23 12:11:24.999  INFO 8956 --- [       Thread-6] o.s.i.monitor.IntegrationMBeanExporter   : Summary on shutdown: greetings-in
2019-08-23 12:11:24.999  INFO 8956 --- [       Thread-6] o.s.i.monitor.IntegrationMBeanExporter   : Summary on shutdown: nullChannel
2019-08-23 12:11:24.999  INFO 8956 --- [       Thread-6] o.s.i.monitor.IntegrationMBeanExporter   : Summary on shutdown: errorChannel
2019-08-23 12:11:24.999  INFO 8956 --- [       Thread-6] o.s.i.monitor.IntegrationMBeanExporter   : Summary on shutdown: _org.springframework.integration.errorLogger.handler

Answer 1

您是否可以尝试将spring-boot-starter-web依赖项添加到您的pom中，看看这是否解决了您的问题？

<dependency>
   <groupId>org.springframework.boot</groupId>
   <artifactId>spring-boot-starter-web</artifactId>
</dependency>