I hereby claim:
- I am theduderog on github.
- I am theduderog (https://keybase.io/theduderog) on keybase.
- I have a public key ASDfD4E-i0J6CcckOoPeyLFp_xZj1BfeAIIG88ENSvDAPAo
To claim this, I am signing this object:
I hereby claim:
To claim this, I am signing this object:
| [2016-08-02 16:26:08,183] INFO Starting stream thread [StreamThread-1] (org.apache.kafka.streams.processor.internals.StreamThread:215) | |
| [2016-08-02 16:26:08,183] INFO Starting stream thread [StreamThread-2] (org.apache.kafka.streams.processor.internals.StreamThread:215) | |
| [2016-08-02 16:26:08,184] INFO Starting stream thread [StreamThread-3] (org.apache.kafka.streams.processor.internals.StreamThread:215) | |
| [2016-08-02 16:26:08,184] INFO Starting stream thread [StreamThread-4] (org.apache.kafka.streams.processor.internals.StreamThread:215) | |
| [2016-08-02 16:26:08,184] INFO Starting stream thread [StreamThread-5] (org.apache.kafka.streams.processor.internals.StreamThread:215) | |
| [2016-08-02 16:26:08,184] INFO Starting stream thread [StreamThread-6] (org.apache.kafka.streams.processor.internals.StreamThread:215) | |
| [2016-08-02 16:26:08,184] INFO Starting stream thread [StreamThread-7] (org.apache.kafka.streams.processor.internals.StreamThread:215) | |
| [2016-08-02 16:26:08,184] INFO Started Kafka Stream process (org.apache.kafka.s |
| var odbc = require('odbc'), | |
| util = require('util'), | |
| count = 0; | |
| var getSchema = function () { | |
| var db = new odbc.Database(); | |
| console.log(util.format('Count %s, time %s', count, new Date())); | |
| console.log(db); |
| var q = require('q') | |
| , assert = require('assert') | |
| , dOrigin = q.defer() | |
| , dDependent = q.defer() //this one gets resolved by callbacks from dOrigin | |
| , dDependent2 = q.defer() //this one gets resolved by linking directly to dOrigin | |
| ; | |
| //Link to dOrigin by registering callbacks | |
| dOrigin.promise.then( | |
| function (result) { |
| tell application "Microsoft Outlook" | |
| set myAlias to "[email protected]" | |
| set listMessages to selected objects | |
| set theMessage to first item of listMessages | |
| set outgoingMessage to reply to theMessage | |
| set theSender to sender of outgoingMessage | |
| set theSenderAddress to the address of theSender | |
| set theSenderName to the name of theSender |
| import logging | |
| import simplejson | |
| from twisted.internet import reactor, defer | |
| from stompest.async import StompConfig, StompCreator | |
| class IncrementTransformer(object): | |
| IN_QUEUE = '/queue/testIn' | |
| OUT_QUEUE = '/queue/testOut' | |
| ERROR_QUEUE = '/queue/testTransformerError' |
| from stompest.simple import Stomp | |
| QUEUE = '/queue/simpleTest' | |
| stomp = Stomp('localhost', 61613) | |
| stomp.connect() | |
| stomp.send(QUEUE, 'test message1') | |
| stomp.send(QUEUE, 'test message2') | |
| stomp.disconnect() |
| from twisted.internet import defer, reactor | |
| @defer.inlineCallbacks | |
| def main(): | |
| client = Client() | |
| foo_with_timeout = timeout(5)(client.foo) | |
| try: | |
| result = yield foo_with_timeout(x=1, y=2) | |
| finally: | |
| reactor.stop() |
| # | |
| # This gist is released under Creative Commons Public Domain Dedication License CC0 1.0 | |
| # http://creativecommons.org/publicdomain/zero/1.0/ | |
| # | |
| from twisted.internet import defer, reactor | |
| class TimeoutError(Exception): | |
| """Raised when time expires in timeout decorator""" |