Springインテグレーションで@MessageEndpointを指定しない@ServiceActivatorアノテーション設定

Question

Spring Integration（バージョン4.0.6）を使用した単純なtcpサーバーのjava/annotationベースのxml構成を使用しようとしています。 @MessageEndpointを使って次のように動作しています。問題は何らかの理由で@MessageEndpointでアノテーションされたクラスが静的でなければならないことです。便利なことをするために豆を入れることはできません。 私が理解しているように、@MessageEndpointなしで@ServiceActivatorを使用することは可能ですが、どのように把握できませんでした。

これは私が今持っているものです。コメントでは、私が置き換えようとしていたxmlの部分を見ることができます。

@Configuration 
@EnableIntegration 
public class TcpServerContextConfiguration { 
// <int-ip:tcp-connection-factory id="crLfServer" 
// type="server" 
// port="5678" 
// single-use="true" 
// so-timeout="10000"/> 

    @Bean 
    TcpNetServerConnectionFactory crLfServer() { 
     TcpNetServerConnectionFactory factory = new TcpNetServerConnectionFactory(5678); 
     factory.setSingleUse(true); 
     factory.setSoTimeout(10000); 
     return factory; 
    } 

// <int-ip:tcp-inbound-gateway id="gatewayCrLf" 
// connection-factory="crLfServer" 
// request-channel="serverBytes2StringChannel"/> 

    @Bean 
    public TcpInboundGateway gatewayCrLf() { 
     TcpInboundGateway gateway = new TcpInboundGateway(); 
     gateway.setConnectionFactory(crLfServer()); 
     gateway.setRequestChannel(serverBytes2StringChannel()); 
     return gateway; 
    } 

    @Bean 
    public MessageChannel serverBytes2StringChannel() { 
     return new DirectChannel(); 
    } 

// <int:channel id="toSA" /> 

    @Bean 
    public MessageChannel toSA() { 
     return new DirectChannel(); 
    } 

// <int:service-activator input-channel="toSA" 
// ref="echoService" 
// method="test"/> 
// 
// <bean id="echoService" 
// class="com.posera.www.poseraStats.site.EchoService" /> 

    @MessageEndpoint 
    public static class Echo { 

     @ServiceActivator(inputChannel="toSA") 
     public String echoService(String req) { 
      return "echo:" + req; 
     } 
    } 


// <int:object-to-string-transformer id="serverBytes2String" 
// input-channel="serverBytes2StringChannel" 
// output-channel="toSA"/> 

    @Bean 
    @Transformer(inputChannel="serverBytes2StringChannel", outputChannel="toSA") 
    public org.springframework.integration.transformer.Transformer serverBytes2String() { 
     return new ObjectToStringTransformer(); 
    } 
} 

は、だから私は@MessageEndpointと、次のコードを試してみましたが、それは失敗します。

@Bean 
@ServiceActivator(inputChannel="toSA") 
public MessageHandler newEchoService() { 
} 

しかし、私：私は、私がすべきこのような何かを探しています答えを推測

@ServiceActivator(inputChannel="toSA") 
public String echoService(String req) { 
    return "echo:" + req; 
} 

この時点でString型の入力チャンネルに使用する必要があるMessageHandlerインターフェイスの実装がわからない場合

ありがとうございます。

Answer 1

Beanクラスは静的クラスまたはトップレベルクラスでなければなりません。

静的クラスはOKですが、あなたはautowireまたはインスタンスに他のBeanを注入するBeanインスタンスを宣言する必要が...

@Bean Foo foo() { 
    return new Foo(); 
} 

public static class Foo { 

    @Autowired 
    private Bar bar; 

    ... 
} 

それとも、注釈を付ける場合は、あなたのTcpServerContextConfiguration@MessageEndpointと、あなただけ使用することができます@ServiceActivatorスタイルは@Beanなし。 4.3.x（現在は4.3.5）にアップグレードすると、クラスレベルで@MessageEndpointは不要になります。