Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * Copyright 2002-2013 the original author or authors.
   *
   * 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.
  */
 
 package org.springframework.messaging.support;
 
 import java.util.List;
 
 
Abstract base class for org.springframework.messaging.MessageChannel implementations.

Author(s):
Rossen Stoyanchev
Since:
4.0
 
 public abstract class AbstractMessageChannel implements MessageChannelBeanNameAware  {
 
 	protected final Log logger = LogFactory.getLog(getClass());
 
 
 	private String beanName;
 
 
 	public AbstractMessageChannel() {
 		this. = getClass().getSimpleName() + "@" + ObjectUtils.getIdentityHexString(this);
 	}

Used primarily for logging purposes.

 
 	public void setBeanName(String name) {
 		this. = name;
 	}

Returns:
the name for this channel.
 
 	public String getBeanName() {
 		return this.;
 	}

Set the list of channel interceptors. This will clear any existing interceptors.
 
 	public void setInterceptors(List<ChannelInterceptorinterceptors) {
 		this..set(interceptors);
 	}

Add a channel interceptor to the end of the list.
 
 	public void addInterceptor(ChannelInterceptor interceptor) {
 		this..add(interceptor);
 	}

Return a read-only list of the configured interceptors.
 
 	}

Exposes the interceptor list for subclasses.
 
 		return this.;
 	}
 
 
 	public final boolean send(Message<?> message) {
 		return send(message);
 	}
	public final boolean send(Message<?> messagelong timeout) {
		Assert.notNull(message"Message must not be null");
			.trace("[" + this. + "] sending message id=" + message.getHeaders().getId());
		}
		message = this..preSend(messagethis);
		if (message == null) {
			return false;
		}
		try {
			boolean sent = sendInternal(messagetimeout);
			this..postSend(messagethissent);
			return sent;
		}
		catch (Exception e) {
			if (e instanceof MessagingException) {
				throw (MessagingExceptione;
			}
			throw new MessageDeliveryException(message,
					"Failed to send message to channel '" + this.getBeanName() + "'"e);
		}
	}
	protected abstract boolean sendInternal(Message<?> messagelong timeout);
	public String toString() {
		return "MessageChannel [name=" + this. + "]";
	}
New to GrepCode? Check out our FAQ X