Skip to content

Commit

Permalink
INT-3189 Fix JavaDocs
Browse files Browse the repository at this point in the history
Links to classes moved to `spring-messaging`.

Also `MessageHeaders` was inadvertently added back in by the
last merge.

JIRA: https://jira.springsource.org/browse/INT-3189

__NOTE: Merge to 4.0.0-WIP, not master__
  • Loading branch information
garyrussell committed Nov 27, 2013
1 parent 6fd8d1d commit 7da027a
Show file tree
Hide file tree
Showing 12 changed files with 22 additions and 294 deletions.

This file was deleted.

Original file line number Diff line number Diff line change
Expand Up @@ -54,7 +54,7 @@ public void setExpectedType(Class<?> expectedType) {

/**
* Evaluate the expression provided on the messages (a collection) in the group, and delegate to the
* {@link MessagingTemplate} to send downstream.
* {@link org.springframework.integration.core.MessagingTemplate} to send downstream.
*/
@Override
protected Object aggregatePayloads(MessageGroup group, Map<String, Object> headers) {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -20,10 +20,10 @@
import java.util.concurrent.PriorityBlockingQueue;
import java.util.concurrent.atomic.AtomicLong;

import org.springframework.messaging.Message;
import org.springframework.messaging.MessageHeaders;
import org.springframework.integration.EiMessageHeaderAccessor;
import org.springframework.integration.util.UpperBound;
import org.springframework.messaging.Message;
import org.springframework.messaging.MessageHeaders;

/**
* A message channel that prioritizes messages based on a {@link Comparator}.
Expand All @@ -43,7 +43,7 @@ public class PriorityChannel extends QueueChannel {
* is a non-positive value, the queue will be unbounded. Message priority
* will be determined by the provided {@link Comparator}. If the comparator
* is <code>null</code>, the priority will be based upon the value of
* {@link MessageHeaders#getPriority()}.
* {@link EiMessageHeaderAccessor#getPriority()}.
*/
public PriorityChannel(int capacity, Comparator<Message<?>> comparator) {
super(new PriorityBlockingQueue<Message<?>>(11, new SequenceFallbackComparator(comparator)));
Expand All @@ -52,7 +52,7 @@ public PriorityChannel(int capacity, Comparator<Message<?>> comparator) {

/**
* Create a channel with the specified queue capacity. Message priority
* will be based upon the value of {@link MessageHeaders#getPriority()}.
* will be based upon the value of {@link EiMessageHeaderAccessor#getPriority()}.
*/
public PriorityChannel(int capacity) {
this(capacity, null);
Expand All @@ -62,15 +62,15 @@ public PriorityChannel(int capacity) {
* Create a channel with an unbounded queue. Message priority will be
* determined by the provided {@link Comparator}. If the comparator
* is <code>null</code>, the priority will be based upon the value of
* {@link MessageHeaders#getPriority()}.
* {@link EiMessageHeaderAccessor#getPriority()}.
*/
public PriorityChannel(Comparator<Message<?>> comparator) {
this(0, comparator);
}

/**
* Create a channel with an unbounded queue. Message priority will be
* based on the value of {@link MessageHeaders#getPriority()}.
* based on the value of {@link EiMessageHeaderAccessor#getPriority()}.
*/
public PriorityChannel() {
this(0, null);
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -121,7 +121,7 @@ public void setMaxSubscribers(int maxSubscribers) {

/**
* If at least this number of subscribers receive the message,
* {@link #send(org.springframework.integration.Message)}
* {@link #send(org.springframework.messaging.Message)}
* will return true. Default: 0.
* @param minSubscribers The minimum number of subscribers.
*/
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@

/**
* Implementations of this interface are {@link InboundMessageMapper}s
* that map a {@link MethodArgsHolder} to a {@link org.springframework.integration.Message}.
* that map a {@link MethodArgsHolder} to a {@link org.springframework.messaging.Message}.
*
* @author Gary Russell
* @since 3.0
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -19,14 +19,13 @@
import org.springframework.expression.Expression;
import org.springframework.expression.spel.standard.SpelExpressionParser;
import org.springframework.expression.spel.support.StandardEvaluationContext;
import org.springframework.integration.core.MessagingTemplate;
import org.springframework.integration.expression.ExpressionUtils;
import org.springframework.integration.message.AdviceMessage;
import org.springframework.messaging.Message;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.MessageHandler;
import org.springframework.messaging.MessageHeaders;
import org.springframework.messaging.MessagingException;
import org.springframework.integration.core.MessagingTemplate;
import org.springframework.messaging.support.ErrorMessage;
import org.springframework.util.Assert;

Expand All @@ -35,7 +34,7 @@
* Two expressions 'onSuccessExpression' and 'onFailureExpression' are evaluated when
* appropriate. If the evaluation returns a result, a message is sent to the onSuccessChannel
* or onFailureChannel as appropriate; the message is the input message with a header
* {@link MessageHeaders#POSTPROCESS_RESULT} containing the evaluation result.
* {@link org.springframework.integration.EiMessageHeaderAccessor#POSTPROCESS_RESULT} containing the evaluation result.
* The failure expression is NOT evaluated if the success expression throws an exception.
* @author Gary Russell
* @since 2.2
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -60,7 +60,7 @@ public abstract class AbstractMappingMessageRouter extends AbstractMessageRouter

/**
* Provide mappings from channel keys to channel names.
* Channel names will be resolved by the {@link ChannelResolver}.
* Channel names will be resolved by the {@link DestinationResolver}.
*/
public void setChannelMappings(Map<String, String> channelMappings) {
Map<String, String> oldChannelMappings = this.channelMappings;
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@
* method's return value may be a single MessageChannel instance, a single
* String to be interpreted as a channel name, or a Collection (or Array) of
* either type. If the method returns channel names, then a
* {@link ChannelResolver} is required.
* {@link org.springframework.messaging.core.DestinationResolver} is required.
*
* @author Mark Fisher
* @author Artem Bilan
Expand Down
Loading

0 comments on commit 7da027a

Please sign in to comment.