Hiram Chirino chirino
chirino
/ gist:8937804
Last active
August 29, 2015 13:56
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| import org.vertx.java.core.AsyncResult; | |
| import org.vertx.java.core.Handler; | |
| import org.vertx.java.core.Vertx; | |
| import org.vertx.java.core.VertxFactory; | |
| import org.vertx.java.core.buffer.Buffer; | |
| import org.vertx.java.core.net.NetServer; | |
| import org.vertx.java.core.net.NetSocket; | |
| import javax.net.SocketFactory; | |
| import java.io.IOException; |
chirino
/ gist:8936409
Created
February 11, 2014 14:59
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| public void handle(final NetSocket socket) { | |
| socket.dataHandler(new Handler<Buffer>() { | |
| Buffer received = new Buffer(); | |
| @Override | |
| public void handle(Buffer event) { | |
| received.appendBuffer(event); | |
| LOG.info("Received a buffer, matching protocols against: " + received.length()); | |
| for (final Protocol protocol : protocols) { | |
| if( protocol.matches(received) ) { |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Scanning dependencies of target cproton_perl | |
| [ 81%] Building C object proton-c/bindings/perl/CMakeFiles/cproton_perl.dir/perlPERL_wrap.c.o | |
| /Users/chirino/sandbox/qpid-proton/proton-c/bindings/perl/perlPERL_wrap.c:12448:14: warning: 20 enumeration values not handled in switch: 'PN_BOOL', 'PN_UBYTE', 'PN_USHORT'... | |
| [-Wswitch] | |
| switch((&result)->type) | |
| ^ | |
| /Users/chirino/sandbox/qpid-proton/proton-c/bindings/perl/perlPERL_wrap.c:12899:14: warning: 20 enumeration values not handled in switch: 'PN_BOOL', 'PN_UBYTE', 'PN_USHORT'... | |
| [-Wswitch] | |
| switch((&result)->type) | |
| ^ |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| [ 81%] Building C object proton-c/bindings/perl/CMakeFiles/cproton_perl.dir/perlPERL_wrap.c.o | |
| In file included from /Users/chirino/sandbox/qpid-proton/proton-c/bindings/perl/perlPERL_wrap.c:1585: | |
| In file included from /Users/chirino/sandbox/qpid-proton/proton-c/include/proton/engine.h:31: | |
| In file included from /Users/chirino/sandbox/qpid-proton/proton-c/include/proton/codec.h:26: | |
| /Users/chirino/sandbox/qpid-proton/proton-c/include/proton/object.h:74:11: error: unknown type name 'bool' | |
| PN_EXTERN bool pn_equals(void *a, void *b); | |
| ^ | |
| /Users/chirino/sandbox/qpid-proton/proton-c/include/proton/object.h:85:11: error: unknown type name 'bool' | |
| PN_EXTERN bool pn_list_remove(pn_list_t *list, void *value); | |
| ^ |
chirino
/ gist:7828221
Created
December 6, 2013 16:56
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| (function (Perspective) { | |
| Perspective.defaultPageLocation = "#/activemq"; | |
| })(Perspective || {}); |
chirino
/ gist:7156013
Created
October 25, 2013 14:57
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| fabric:mq-create --group testGroup testBroker | |
| 21955 [main] ERROR org.ops4j.pax.exam.junit.JUnit4TestRunner - Exception | |
| org.ops4j.pax.exam.TestContainerException: [testMQCreateWithFailover(org.fusesource.mq.itests.GracefullFailOverTest): Profile 'mq-broker-testGroup.testBroker' does not exist in version '1.0'.] | |
| at org.ops4j.pax.exam.invoker.junit.internal.JUnitProbeInvoker.invokeViaJUnit(JUnitProbeInvoker.java:128) | |
| at org.ops4j.pax.exam.invoker.junit.internal.JUnitProbeInvoker.findAndInvoke(JUnitProbeInvoker.java:94) | |
| at org.ops4j.pax.exam.invoker.junit.internal.JUnitProbeInvoker.call(JUnitProbeInvoker.java:77) | |
| at sun.reflect.NativeMethodAccessorImpl.invoke0(Native Method) | |
| at sun.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:57) | |
| at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43) |
chirino
/ gist:6934154
Created
October 11, 2013 12:57
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| 2013-10-11 08:56:23,018 | ERROR | 7d-6945aa67e5c8) | configadmin | ? ? | 5 - org.apache.felix.configadmin - 1.6.0 | [org.osgi.service.cm.ManagedServiceFactory, id=213, bundle=89/mvn:org.apache.activemq/activemq-osgi/5.9-SNAPSHOT]: Unexpected problem updating configuration org.apache.activemq.server.d1274f9e-7548-495e-b17d-6945aa67e5c8 | |
| java.lang.NoClassDefFoundError: org/slf4j/LoggerFactory | |
| at org.apache.zookeeper.ZooKeeper.<clinit>(ZooKeeper.java:94) | |
| at org.linkedin.zookeeper.client.ZooKeeperFactory.createZooKeeper(ZooKeeperFactory.java:62) | |
| at org.apache.activemq.leveldb.replicated.groups.ZKClient.connect(ZKClient.java:192) | |
| at org.apache.activemq.leveldb.replicated.groups.ZKClient.doStart(ZKClient.java:79) | |
| at org.apache.activemq.leveldb.replicated.groups.ZKClient.start(ZKClient.java:66) | |
| at org.apache.activemq.leveldb.replicated.ElectingLevelDBStore.init(ElectingLevelDBStore.scala:179) | |
| at org.apache.activemq.broker.LockableServiceSupport.preStart(L |
chirino
/ gist:6891902
Last active
December 25, 2015 00:59
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| package org.apache.activemq.advisory; | |
| import org.apache.activemq.ActiveMQConnection; | |
| import org.apache.activemq.ActiveMQConnectionFactory; | |
| import org.apache.activemq.transport.TransportListener; | |
| import org.apache.activemq.transport.tcp.TcpTransport; | |
| import javax.jms.MessageConsumer; | |
| import javax.jms.Session; | |
| import javax.jms.TemporaryQueue; |
chirino
/ gist:6242408
Last active
December 21, 2015 03:29
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| val scenario = new com.github.stomp.benchmark.NonBlockingScenario | |
| scenario.host = "localhost" | |
| scenario.port = 61613 | |
| scenario.display_errors = true | |
| scenario.login = Some("admin") | |
| scenario.passcode = Some("password") | |
| scenario.destination_count = 1; | |
| scenario.destination_type = "queue"; |
chirino
/ gist:6080386
Created
July 25, 2013 14:43
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| diff --git a/src/stomp.coffee b/src/stomp.coffee | |
| index 7408f23..983001f 100644 | |
| --- a/src/stomp.coffee | |
| +++ b/src/stomp.coffee | |
| @@ -19,6 +19,8 @@ Byte = | |
| # NULL byte (octet 0) | |
| NULL: '\x00' | |
| +MAX_FRAME_SIZE = 16*1024 | |
| + |