root
/
spring-framework
mirror of https://github.com/spring-projects/spring-framework.git
1
0
Fork 0
Code Issues Actions 8 Packages Projects Releases Wiki Activity

Polishing

This commit is contained in:
Juergen Hoeller 2015-06-11 12:33:30 +02:00
parent 32b9ea9e9f
commit ad55687627
7 changed files with 20 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
spring-jms/src/main/java/org/springframework/jms/connection/CachedMessageProducer.java
View File

@ -1,5 +1,5 @@
/* /*
* Copyright 2002-2014 the original author or authors. * Copyright 2002-2015 the original author or authors.
* *
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
@ -41,6 +41,8 @@ import org.springframework.util.ReflectionUtils;
*/ */
class CachedMessageProducer implements MessageProducer, QueueSender, TopicPublisher { class CachedMessageProducer implements MessageProducer, QueueSender, TopicPublisher {
// Various JMS 2.0 MessageProducer methods, if available
private static final Method setDeliveryDelayMethod = private static final Method setDeliveryDelayMethod =
ClassUtils.getMethodIfAvailable(MessageProducer.class, "setDeliveryDelay", long.class); ClassUtils.getMethodIfAvailable(MessageProducer.class, "setDeliveryDelay", long.class);

4
spring-jms/src/main/java/org/springframework/jms/connection/CachingConnectionFactory.java
View File

@ -1,5 +1,5 @@
/* /*
* Copyright 2002-2014 the original author or authors. * Copyright 2002-2015 the original author or authors.
* *
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
@ -78,9 +78,11 @@ import org.springframework.util.ReflectionUtils;
*/ */
public class CachingConnectionFactory extends SingleConnectionFactory { public class CachingConnectionFactory extends SingleConnectionFactory {
/** The JMS 2.0 Session.createSharedConsumer method, if available */
private static final Method createSharedConsumerMethod = ClassUtils.getMethodIfAvailable( private static final Method createSharedConsumerMethod = ClassUtils.getMethodIfAvailable(
Session.class, "createSharedConsumer", Topic.class, String.class, String.class); Session.class, "createSharedConsumer", Topic.class, String.class, String.class);
/** The JMS 2.0 Session.createSharedDurableConsumer method, if available */
private static final Method createSharedDurableConsumerMethod = ClassUtils.getMethodIfAvailable( private static final Method createSharedDurableConsumerMethod = ClassUtils.getMethodIfAvailable(
Session.class, "createSharedDurableConsumer", Topic.class, String.class, String.class); Session.class, "createSharedDurableConsumer", Topic.class, String.class, String.class);

3
spring-jms/src/main/java/org/springframework/jms/core/JmsTemplate.java
View File

@ -1,5 +1,5 @@
/* /*
* Copyright 2002-2014 the original author or authors. * Copyright 2002-2015 the original author or authors.
* *
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
@ -101,6 +101,7 @@ public class JmsTemplate extends JmsDestinationAccessor implements JmsOperations
public static final long RECEIVE_TIMEOUT_INDEFINITE_WAIT = 0; public static final long RECEIVE_TIMEOUT_INDEFINITE_WAIT = 0;
/** The JMS 2.0 MessageProducer.setDeliveryDelay method, if available */
private static final Method setDeliveryDelayMethod = private static final Method setDeliveryDelayMethod =
ClassUtils.getMethodIfAvailable(MessageProducer.class, "setDeliveryDelay", long.class); ClassUtils.getMethodIfAvailable(MessageProducer.class, "setDeliveryDelay", long.class);

2
spring-jms/src/main/java/org/springframework/jms/listener/AbstractMessageListenerContainer.java
View File

@ -134,9 +134,11 @@ import org.springframework.util.ReflectionUtils;
public abstract class AbstractMessageListenerContainer extends AbstractJmsListeningContainer public abstract class AbstractMessageListenerContainer extends AbstractJmsListeningContainer
implements MessageListenerContainer { implements MessageListenerContainer {
/** The JMS 2.0 Session.createSharedConsumer method, if available */
private static final Method createSharedConsumerMethod = ClassUtils.getMethodIfAvailable( private static final Method createSharedConsumerMethod = ClassUtils.getMethodIfAvailable(
Session.class, "createSharedConsumer", Topic.class, String.class, String.class); Session.class, "createSharedConsumer", Topic.class, String.class, String.class);
/** The JMS 2.0 Session.createSharedDurableConsumer method, if available */
private static final Method createSharedDurableConsumerMethod = ClassUtils.getMethodIfAvailable( private static final Method createSharedDurableConsumerMethod = ClassUtils.getMethodIfAvailable(
Session.class, "createSharedDurableConsumer", Topic.class, String.class, String.class); Session.class, "createSharedDurableConsumer", Topic.class, String.class, String.class);

1
spring-web/src/main/java/org/springframework/web/context/request/WebRequest.java
View File

@ -221,7 +221,6 @@ public interface WebRequest extends RequestAttributes {
* @return whether the request qualifies as not modified, * @return whether the request qualifies as not modified,
* allowing to abort request processing and relying on the response * allowing to abort request processing and relying on the response
* telling the client that the content has not been modified * telling the client that the content has not been modified
*
* @since 4.2 * @since 4.2
*/ */
boolean checkNotModified(String etag, long lastModifiedTimestamp); boolean checkNotModified(String etag, long lastModifiedTimestamp);

4
spring-web/src/main/java/org/springframework/web/context/request/async/NoSupportAsyncWebRequest.java
View File

@ -1,5 +1,5 @@
/* /*
* Copyright 2002-2012 the original author or authors. * Copyright 2002-2015 the original author or authors.
* *
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
@ -33,6 +33,7 @@ public class NoSupportAsyncWebRequest extends ServletWebRequest implements Async
super(request, response); super(request, response);
} }
@Override @Override
public void addCompletionHandler(Runnable runnable) { public void addCompletionHandler(Runnable runnable) {
// ignored // ignored
@ -53,6 +54,7 @@ public class NoSupportAsyncWebRequest extends ServletWebRequest implements Async
return false; return false;
} }
// Not supported // Not supported
@Override @Override

12
spring-web/src/main/java/org/springframework/web/context/request/async/StandardServletAsyncWebRequest.java
View File

@ -1,5 +1,5 @@
/* /*
* Copyright 2002-2012 the original author or authors. * Copyright 2002-2015 the original author or authors.
* *
* Licensed under the Apache License, Version 2.0 (the "License"); * Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License. * you may not use this file except in compliance with the License.
@ -35,7 +35,7 @@ import org.springframework.web.context.request.ServletWebRequest;
* <p>The servlet and all filters involved in an async request must have async * <p>The servlet and all filters involved in an async request must have async
* support enabled using the Servlet API or by adding an * support enabled using the Servlet API or by adding an
* {@code <async-support>true</async-support>} element to servlet and filter * {@code <async-support>true</async-support>} element to servlet and filter
* declarations in web.xml * declarations in {@code web.xml}.
* *
* @author Rossen Stoyanchev * @author Rossen Stoyanchev
* @since 3.2 * @since 3.2
@ -62,9 +62,9 @@ public class StandardServletAsyncWebRequest extends ServletWebRequest implements
super(request, response); super(request, response);
} }
/** /**
* {@inheritDoc} * In Servlet 3 async processing, the timeout period begins after the
* <p>In Servlet 3 async processing, the timeout period begins after the
* container processing thread has exited. * container processing thread has exited.
*/ */
@Override @Override
@ -85,7 +85,7 @@ public class StandardServletAsyncWebRequest extends ServletWebRequest implements
@Override @Override
public boolean isAsyncStarted() { public boolean isAsyncStarted() {
return ((this.asyncContext != null) && getRequest().isAsyncStarted()); return (this.asyncContext != null && getRequest().isAsyncStarted());
} }
/** /**
@ -106,6 +106,7 @@ public class StandardServletAsyncWebRequest extends ServletWebRequest implements
"or by adding \"<async-supported>true</async-supported>\" to servlet and " + "or by adding \"<async-supported>true</async-supported>\" to servlet and " +
"filter declarations in web.xml."); "filter declarations in web.xml.");
Assert.state(!isAsyncComplete(), "Async processing has already completed"); Assert.state(!isAsyncComplete(), "Async processing has already completed");
if (isAsyncStarted()) { if (isAsyncStarted()) {
return; return;
} }
@ -122,6 +123,7 @@ public class StandardServletAsyncWebRequest extends ServletWebRequest implements
this.asyncContext.dispatch(); this.asyncContext.dispatch();
} }
// --------------------------------------------------------------------- // ---------------------------------------------------------------------
// Implementation of AsyncListener methods // Implementation of AsyncListener methods
// --------------------------------------------------------------------- // ---------------------------------------------------------------------