Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * #%L
   * Service Activity Monitoring :: Agent
   * %%
   * Copyright (C) 2011 Talend Inc.
   * %%
   * Licensed under the Apache License, Version 2.0 (the "License");
   * you may not use this file except in compliance with the License.
   * You may obtain a copy of the License at
  * 
  *      http://www.apache.org/licenses/LICENSE-2.0
  * 
  * Unless required by applicable law or agreed to in writing, software
  * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
  * #L%
  */
 package org.talend.esb.sam.agent.feature;
 
 
Feature adds FlowIdProducer Interceptor and EventProducer Interceptor.
 
 public class EventFeature extends AbstractFeature implements InitializingBean {
 
     private MessageToEventMapper mapper;
     private EventHandler eventSender;
     private boolean logMessageContent;
     protected static Logger logger = Logger.getLogger(EventFeature.class.getName());
 
     public EventFeature() {
         super();
     }
 
     @Override
     protected void initializeProvider(InterceptorProvider providerBus bus) {
         if ( == null) {
             throw new RuntimeException("Mapper must be set on EventFeature");
         }
         if ( == null) {
             throw new RuntimeException("EventSender must be set on EventFeature");
         }
         super.initializeProvider(providerbus);
 
         FlowIdProducerIn<MessageflowIdProducerIn = new FlowIdProducerIn<Message>();
         provider.getInInterceptors().add(flowIdProducerIn);
         provider.getInFaultInterceptors().add(flowIdProducerIn);
 
         FlowIdProducerOut<MessageflowIdProducerOut = new FlowIdProducerOut<Message>();
         provider.getOutInterceptors().add(flowIdProducerOut);
         provider.getOutFaultInterceptors().add(flowIdProducerOut);
 
         WireTapIn wireTapIn = new WireTapIn();
         provider.getInInterceptors().add(wireTapIn);
         provider.getInInterceptors().add(epi);
         provider.getInFaultInterceptors().add(epi);
 
         WireTapOut wireTapOut = new WireTapOut(epi);
         provider.getOutInterceptors().add(wireTapOut);
         provider.getOutFaultInterceptors().add(wireTapOut);
     }
 
     public void setMapper(MessageToEventMapper mapper) {
         this. = mapper;
     }
 
     public void setEventSender(EventHandler eventSender) {
         this. = eventSender;
     }
 
     public void setLogMessageContent(boolean logMessageContent) {
         this. = logMessageContent;
     }
 
     @Override
     public void afterPropertiesSet() throws Exception {
         if ( == null) {
             throw new RuntimeException("Mapper must be set on EventFeature");
         }
         if ( == null) {
             throw new RuntimeException("EventSender must be set on EventFeature");
        }
        .info("Eventsender and mapper are set correctly");
    }
    
New to GrepCode? Check out our FAQ X