You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ma...@apache.org on 2017/03/30 08:54:38 UTC
[1/3] activemq-artemis git commit: This closes #1158
Repository: activemq-artemis
Updated Branches:
refs/heads/master 266b1f31b -> 07597ba95
This closes #1158
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/07597ba9
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/07597ba9
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/07597ba9
Branch: refs/heads/master
Commit: 07597ba959516c8e3a60d3f4565bf1ad340530be
Parents: 266b1f3 9bef242
Author: Martyn Taylor <mt...@redhat.com>
Authored: Thu Mar 30 09:54:26 2017 +0100
Committer: Martyn Taylor <mt...@redhat.com>
Committed: Thu Mar 30 09:54:26 2017 +0100
----------------------------------------------------------------------
.../artemis/cli/commands/etc/amqp-acceptor.txt | 2 +-
.../artemis/cli/commands/etc/mqtt-acceptor.txt | 2 +-
.../artemis/cli/commands/etc/stomp-acceptor.txt | 2 +-
.../remoting/impl/netty/TransportConstants.java | 4 ++--
.../amqp/proton/ProtonServerReceiverContext.java | 17 ++++++++---------
scripts/one-test.sh | 2 +-
6 files changed, 14 insertions(+), 15 deletions(-)
----------------------------------------------------------------------
[2/3] activemq-artemis git commit: ARTEMIS-1056 Adjusting Acceptor
values
Posted by ma...@apache.org.
ARTEMIS-1056 Adjusting Acceptor values
I have been doing tests with quiver at large message sizes
the tests would work really slowly without these fixes
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/9bef242b
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/9bef242b
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/9bef242b
Branch: refs/heads/master
Commit: 9bef242b74a89d652398a0dced15073dbb9d470f
Parents: 5ca514a
Author: Clebert Suconic <cl...@apache.org>
Authored: Wed Mar 29 21:41:21 2017 -0400
Committer: Martyn Taylor <mt...@redhat.com>
Committed: Thu Mar 30 09:54:26 2017 +0100
----------------------------------------------------------------------
.../artemis/cli/commands/etc/amqp-acceptor.txt | 2 +-
.../artemis/cli/commands/etc/mqtt-acceptor.txt | 2 +-
.../artemis/cli/commands/etc/stomp-acceptor.txt | 2 +-
.../remoting/impl/netty/TransportConstants.java | 4 ++--
.../amqp/proton/ProtonServerReceiverContext.java | 17 ++++++++---------
5 files changed, 13 insertions(+), 14 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/9bef242b/artemis-cli/src/main/resources/org/apache/activemq/artemis/cli/commands/etc/amqp-acceptor.txt
----------------------------------------------------------------------
diff --git a/artemis-cli/src/main/resources/org/apache/activemq/artemis/cli/commands/etc/amqp-acceptor.txt b/artemis-cli/src/main/resources/org/apache/activemq/artemis/cli/commands/etc/amqp-acceptor.txt
index 71f44b7..743ba95 100644
--- a/artemis-cli/src/main/resources/org/apache/activemq/artemis/cli/commands/etc/amqp-acceptor.txt
+++ b/artemis-cli/src/main/resources/org/apache/activemq/artemis/cli/commands/etc/amqp-acceptor.txt
@@ -1,3 +1,3 @@
<!-- AMQP Acceptor. Listens on default AMQP port for AMQP traffic.-->
- <acceptor name="amqp">tcp://${host}:${amqp.port}?protocols=AMQP;useEpoll=true;amqpCredits=1000;amqpMinCredits=300</acceptor>
+ <acceptor name="amqp">tcp://${host}:${amqp.port}?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=AMQP;useEpoll=true;amqpCredits=1000;amqpMinCredits=300</acceptor>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/9bef242b/artemis-cli/src/main/resources/org/apache/activemq/artemis/cli/commands/etc/mqtt-acceptor.txt
----------------------------------------------------------------------
diff --git a/artemis-cli/src/main/resources/org/apache/activemq/artemis/cli/commands/etc/mqtt-acceptor.txt b/artemis-cli/src/main/resources/org/apache/activemq/artemis/cli/commands/etc/mqtt-acceptor.txt
index ceaf615..a307e63 100644
--- a/artemis-cli/src/main/resources/org/apache/activemq/artemis/cli/commands/etc/mqtt-acceptor.txt
+++ b/artemis-cli/src/main/resources/org/apache/activemq/artemis/cli/commands/etc/mqtt-acceptor.txt
@@ -1,3 +1,3 @@
<!-- MQTT Acceptor -->
- <acceptor name="mqtt">tcp://${host}:${mqtt.port}?protocols=MQTT;useEpoll=true</acceptor>
+ <acceptor name="mqtt">tcp://${host}:${mqtt.port}?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=MQTT;useEpoll=true</acceptor>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/9bef242b/artemis-cli/src/main/resources/org/apache/activemq/artemis/cli/commands/etc/stomp-acceptor.txt
----------------------------------------------------------------------
diff --git a/artemis-cli/src/main/resources/org/apache/activemq/artemis/cli/commands/etc/stomp-acceptor.txt b/artemis-cli/src/main/resources/org/apache/activemq/artemis/cli/commands/etc/stomp-acceptor.txt
index bfe4d8b..c10ab2e 100644
--- a/artemis-cli/src/main/resources/org/apache/activemq/artemis/cli/commands/etc/stomp-acceptor.txt
+++ b/artemis-cli/src/main/resources/org/apache/activemq/artemis/cli/commands/etc/stomp-acceptor.txt
@@ -1,3 +1,3 @@
<!-- STOMP Acceptor. -->
- <acceptor name="stomp">tcp://${host}:${stomp.port}?protocols=STOMP;useEpoll=true</acceptor>
+ <acceptor name="stomp">tcp://${host}:${stomp.port}?tcpSendBufferSize=1048576;tcpReceiveBufferSize=1048576;protocols=STOMP;useEpoll=true</acceptor>
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/9bef242b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/TransportConstants.java
----------------------------------------------------------------------
diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/TransportConstants.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/TransportConstants.java
index 4293000..4317a68 100644
--- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/TransportConstants.java
+++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/core/remoting/impl/netty/TransportConstants.java
@@ -179,9 +179,9 @@ public class TransportConstants {
public static final boolean DEFAULT_TCP_NODELAY = true;
- public static final int DEFAULT_TCP_SENDBUFFER_SIZE = 32768;
+ public static final int DEFAULT_TCP_SENDBUFFER_SIZE = 1024 * 1024;
- public static final int DEFAULT_TCP_RECEIVEBUFFER_SIZE = 32768;
+ public static final int DEFAULT_TCP_RECEIVEBUFFER_SIZE = 1024 * 1024;
public static final boolean DEFAULT_HTTP_ENABLED = false;
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/9bef242b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/ProtonServerReceiverContext.java
----------------------------------------------------------------------
diff --git a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/ProtonServerReceiverContext.java b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/ProtonServerReceiverContext.java
index 76ad1ac..fcdced4 100644
--- a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/ProtonServerReceiverContext.java
+++ b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/proton/ProtonServerReceiverContext.java
@@ -146,11 +146,14 @@ public class ProtonServerReceiverContext extends ProtonInitializable implements
public void onMessage(Delivery delivery) throws ActiveMQAMQPException {
Receiver receiver;
try {
- receiver = ((Receiver) delivery.getLink());
if (!delivery.isReadable()) {
return;
}
+ if (delivery.isPartial()) {
+ return;
+ }
+ receiver = ((Receiver) delivery.getLink());
if (delivery.isPartial()) {
return;
@@ -160,11 +163,9 @@ public class ProtonServerReceiverContext extends ProtonInitializable implements
byte[] data;
- synchronized (connection.getLock()) {
- data = new byte[delivery.available()];
- receiver.recv(data, 0, data.length);
- receiver.advance();
- }
+ data = new byte[delivery.available()];
+ receiver.recv(data, 0, data.length);
+ receiver.advance();
if (delivery.getRemoteState() instanceof TransactionalState) {
@@ -174,9 +175,7 @@ public class ProtonServerReceiverContext extends ProtonInitializable implements
sessionSPI.serverSend(tx, receiver, delivery, address, delivery.getMessageFormat(), data);
- synchronized (connection.getLock()) {
- flow(amqpCredits, minCreditRefresh);
- }
+ flow(amqpCredits, minCreditRefresh);
} catch (Exception e) {
log.warn(e.getMessage(), e);
Rejected rejected = new Rejected();
[3/3] activemq-artemis git commit: NO-JIRA: one test script to ignore
checkstyle
Posted by ma...@apache.org.
NO-JIRA: one test script to ignore checkstyle
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/5ca514a2
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/5ca514a2
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/5ca514a2
Branch: refs/heads/master
Commit: 5ca514a2a8fc7959d87a49af4d6faf0ebb2dc357
Parents: 266b1f3
Author: Clebert Suconic <cl...@apache.org>
Authored: Wed Mar 29 18:26:10 2017 -0400
Committer: Martyn Taylor <mt...@redhat.com>
Committed: Thu Mar 30 09:54:26 2017 +0100
----------------------------------------------------------------------
scripts/one-test.sh | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/5ca514a2/scripts/one-test.sh
----------------------------------------------------------------------
diff --git a/scripts/one-test.sh b/scripts/one-test.sh
index 5c2cca8..8cd7b21 100755
--- a/scripts/one-test.sh
+++ b/scripts/one-test.sh
@@ -16,4 +16,4 @@
# specific language governing permissions and limitations
# under the License.
-mvn -Ptests -DfailIfNoTests=false -Pextra-tests -DskipPerformanceTests=false -Dtest=$1 test
+mvn -Ptests -DfailIfNoTests=false -Pextra-tests -DskipStyleCheck=true -DskipPerformanceTests=false -Dtest=$1 test