{"action":"created","comment":{"url":"https://api.github.com/repos/IBMStreams/streamsx.topology/pulls/comments/64610231","id":64610231,"diff_hunk":"@@ -14,24 +14,30 @@\n     PyObject * appCallable = \n       streamsx::topology::Splpy::loadFunction(<%=$pyModule%>, <%=$pyCallableName%>);\n \n+\t<% if ($pystyle eq 'string' or $pystyle eq 'message') { %>\n+\t\tfunction_ = appCallable;\n+\t<%} else {%>\t  \n     // The object to be called is either appCallable for\n     // a function passed into the operator\n     // or a pickled encoded class instance\n     // represented as a string in parameter pyCallable\n-    \n-    <% if ($pyCallable) { %>\n-      // argument is the serialized callable instance\n-      Py_DECREF(appCallable);\n-      appCallable = Py_BuildValue(\"s\", <%=$pyCallable%>);\n-    <%}%>\n+    \t<% if ($pyCallable) { %>","path":"com.ibm.streamsx.topology/com.ibm.streamsx.topology.functional.python/pywrapfunction.cgt","position":17,"original_position":17,"commit_id":"ef90a57dbd84ceffc3fdea2a9452c6068b97c843","original_commit_id":"ef90a57dbd84ceffc3fdea2a9452c6068b97c843","user":{"login":"ddebrunner","id":3769612,"avatar_url":"https://avatars.githubusercontent.com/u/3769612?v=3","gravatar_id":"","url":"https://api.github.com/users/ddebrunner","html_url":"https://github.com/ddebrunner","followers_url":"https://api.github.com/users/ddebrunner/followers","following_url":"https://api.github.com/users/ddebrunner/following{/other_user}","gists_url":"https://api.github.com/users/ddebrunner/gists{/gist_id}","starred_url":"https://api.github.com/users/ddebrunner/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/ddebrunner/subscriptions","organizations_url":"https://api.github.com/users/ddebrunner/orgs","repos_url":"https://api.github.com/users/ddebrunner/repos","events_url":"https://api.github.com/users/ddebrunner/events{/privacy}","received_events_url":"https://api.github.com/users/ddebrunner/received_events","type":"User","site_admin":false},"body":"Try to avoid whitepace changes, it makes it harder to review a change. \r\n\r\nDoesn't seem like there are changes here?????","created_at":"2016-05-25T16:53:43Z","updated_at":"2016-05-25T16:53:43Z","html_url":"https://github.com/IBMStreams/streamsx.topology/pull/396#discussion_r64610231","pull_request_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/pulls/396","_links":{"self":{"href":"https://api.github.com/repos/IBMStreams/streamsx.topology/pulls/comments/64610231"},"html":{"href":"https://github.com/IBMStreams/streamsx.topology/pull/396#discussion_r64610231"},"pull_request":{"href":"https://api.github.com/repos/IBMStreams/streamsx.topology/pulls/396"}}},"pull_request":{"url":"https://api.github.com/repos/IBMStreams/streamsx.topology/pulls/396","id":71110977,"html_url":"https://github.com/IBMStreams/streamsx.topology/pull/396","diff_url":"https://github.com/IBMStreams/streamsx.topology/pull/396.diff","patch_url":"https://github.com/IBMStreams/streamsx.topology/pull/396.patch","issue_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/issues/396","number":396,"state":"open","locked":false,"title":"Mqttconnect","user":{"login":"drhvm","id":17013886,"avatar_url":"https://avatars.githubusercontent.com/u/17013886?v=3","gravatar_id":"","url":"https://api.github.com/users/drhvm","html_url":"https://github.com/drhvm","followers_url":"https://api.github.com/users/drhvm/followers","following_url":"https://api.github.com/users/drhvm/following{/other_user}","gists_url":"https://api.github.com/users/drhvm/gists{/gist_id}","starred_url":"https://api.github.com/users/drhvm/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/drhvm/subscriptions","organizations_url":"https://api.github.com/users/drhvm/orgs","repos_url":"https://api.github.com/users/drhvm/repos","events_url":"https://api.github.com/users/drhvm/events{/privacy}","received_events_url":"https://api.github.com/users/drhvm/received_events","type":"User","site_admin":false},"body":"Support for MQTT Connector. Provides publish and subscribe. Currently there are still configuration parameters the require an integer vs. long that cannot be set but they are not required for basic operation. Since the tests for this function require an external MQTT server running, I created a separate entry in build.xml to run the tests for these functions. Command \"ant test.mqtt.application.api\" will run the MQTT connector tests which reside in mqtest1.py in the python test directory.","created_at":"2016-05-23T19:57:53Z","updated_at":"2016-05-25T16:53:43Z","closed_at":null,"merged_at":null,"merge_commit_sha":"c4fd77f5e26df252b3d75a896d664c5991addad4","assignee":null,"milestone":null,"commits_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/pulls/396/commits","review_comments_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/pulls/396/comments","review_comment_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/pulls/comments{/number}","comments_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/issues/396/comments","statuses_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/statuses/ef90a57dbd84ceffc3fdea2a9452c6068b97c843","head":{"label":"drhvm:mqttconnect","ref":"mqttconnect","sha":"ef90a57dbd84ceffc3fdea2a9452c6068b97c843","user":{"login":"drhvm","id":17013886,"avatar_url":"https://avatars.githubusercontent.com/u/17013886?v=3","gravatar_id":"","url":"https://api.github.com/users/drhvm","html_url":"https://github.com/drhvm","followers_url":"https://api.github.com/users/drhvm/followers","following_url":"https://api.github.com/users/drhvm/following{/other_user}","gists_url":"https://api.github.com/users/drhvm/gists{/gist_id}","starred_url":"https://api.github.com/users/drhvm/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/drhvm/subscriptions","organizations_url":"https://api.github.com/users/drhvm/orgs","repos_url":"https://api.github.com/users/drhvm/repos","events_url":"https://api.github.com/users/drhvm/events{/privacy}","received_events_url":"https://api.github.com/users/drhvm/received_events","type":"User","site_admin":false},"repo":{"id":50875389,"name":"streamsx.topology","full_name":"drhvm/streamsx.topology","owner":{"login":"drhvm","id":17013886,"avatar_url":"https://avatars.githubusercontent.com/u/17013886?v=3","gravatar_id":"","url":"https://api.github.com/users/drhvm","html_url":"https://github.com/drhvm","followers_url":"https://api.github.com/users/drhvm/followers","following_url":"https://api.github.com/users/drhvm/following{/other_user}","gists_url":"https://api.github.com/users/drhvm/gists{/gist_id}","starred_url":"https://api.github.com/users/drhvm/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/drhvm/subscriptions","organizations_url":"https://api.github.com/users/drhvm/orgs","repos_url":"https://api.github.com/users/drhvm/repos","events_url":"https://api.github.com/users/drhvm/events{/privacy}","received_events_url":"https://api.github.com/users/drhvm/received_events","type":"User","site_admin":false},"private":false,"html_url":"https://github.com/drhvm/streamsx.topology","description":"(Incubation) A project that supports building streaming topologies (applications) for IBM Streams in different programming languages, such as Java and Scala.","fork":true,"url":"https://api.github.com/repos/drhvm/streamsx.topology","forks_url":"https://api.github.com/repos/drhvm/streamsx.topology/forks","keys_url":"https://api.github.com/repos/drhvm/streamsx.topology/keys{/key_id}","collaborators_url":"https://api.github.com/repos/drhvm/streamsx.topology/collaborators{/collaborator}","teams_url":"https://api.github.com/repos/drhvm/streamsx.topology/teams","hooks_url":"https://api.github.com/repos/drhvm/streamsx.topology/hooks","issue_events_url":"https://api.github.com/repos/drhvm/streamsx.topology/issues/events{/number}","events_url":"https://api.github.com/repos/drhvm/streamsx.topology/events","assignees_url":"https://api.github.com/repos/drhvm/streamsx.topology/assignees{/user}","branches_url":"https://api.github.com/repos/drhvm/streamsx.topology/branches{/branch}","tags_url":"https://api.github.com/repos/drhvm/streamsx.topology/tags","blobs_url":"https://api.github.com/repos/drhvm/streamsx.topology/git/blobs{/sha}","git_tags_url":"https://api.github.com/repos/drhvm/streamsx.topology/git/tags{/sha}","git_refs_url":"https://api.github.com/repos/drhvm/streamsx.topology/git/refs{/sha}","trees_url":"https://api.github.com/repos/drhvm/streamsx.topology/git/trees{/sha}","statuses_url":"https://api.github.com/repos/drhvm/streamsx.topology/statuses/{sha}","languages_url":"https://api.github.com/repos/drhvm/streamsx.topology/languages","stargazers_url":"https://api.github.com/repos/drhvm/streamsx.topology/stargazers","contributors_url":"https://api.github.com/repos/drhvm/streamsx.topology/contributors","subscribers_url":"https://api.github.com/repos/drhvm/streamsx.topology/subscribers","subscription_url":"https://api.github.com/repos/drhvm/streamsx.topology/subscription","commits_url":"https://api.github.com/repos/drhvm/streamsx.topology/commits{/sha}","git_commits_url":"https://api.github.com/repos/drhvm/streamsx.topology/git/commits{/sha}","comments_url":"https://api.github.com/repos/drhvm/streamsx.topology/comments{/number}","issue_comment_url":"https://api.github.com/repos/drhvm/streamsx.topology/issues/comments{/number}","contents_url":"https://api.github.com/repos/drhvm/streamsx.topology/contents/{+path}","compare_url":"https://api.github.com/repos/drhvm/streamsx.topology/compare/{base}...{head}","merges_url":"https://api.github.com/repos/drhvm/streamsx.topology/merges","archive_url":"https://api.github.com/repos/drhvm/streamsx.topology/{archive_format}{/ref}","downloads_url":"https://api.github.com/repos/drhvm/streamsx.topology/downloads","issues_url":"https://api.github.com/repos/drhvm/streamsx.topology/issues{/number}","pulls_url":"https://api.github.com/repos/drhvm/streamsx.topology/pulls{/number}","milestones_url":"https://api.github.com/repos/drhvm/streamsx.topology/milestones{/number}","notifications_url":"https://api.github.com/repos/drhvm/streamsx.topology/notifications{?since,all,participating}","labels_url":"https://api.github.com/repos/drhvm/streamsx.topology/labels{/name}","releases_url":"https://api.github.com/repos/drhvm/streamsx.topology/releases{/id}","deployments_url":"https://api.github.com/repos/drhvm/streamsx.topology/deployments","created_at":"2016-02-01T22:15:03Z","updated_at":"2016-02-01T22:15:04Z","pushed_at":"2016-05-25T15:21:04Z","git_url":"git://github.com/drhvm/streamsx.topology.git","ssh_url":"git@github.com:drhvm/streamsx.topology.git","clone_url":"https://github.com/drhvm/streamsx.topology.git","svn_url":"https://github.com/drhvm/streamsx.topology","homepage":"http://ibmstreams.github.io/streamsx.topology","size":6255,"stargazers_count":0,"watchers_count":0,"language":"Java","has_issues":false,"has_downloads":true,"has_wiki":true,"has_pages":false,"forks_count":0,"mirror_url":null,"open_issues_count":0,"forks":0,"open_issues":0,"watchers":0,"default_branch":"master"}},"base":{"label":"IBMStreams:python_spl","ref":"python_spl","sha":"b6a32e3fb2b079f907d78a40a3f86d36d8ff1003","user":{"login":"IBMStreams","id":5439177,"avatar_url":"https://avatars.githubusercontent.com/u/5439177?v=3","gravatar_id":"","url":"https://api.github.com/users/IBMStreams","html_url":"https://github.com/IBMStreams","followers_url":"https://api.github.com/users/IBMStreams/followers","following_url":"https://api.github.com/users/IBMStreams/following{/other_user}","gists_url":"https://api.github.com/users/IBMStreams/gists{/gist_id}","starred_url":"https://api.github.com/users/IBMStreams/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/IBMStreams/subscriptions","organizations_url":"https://api.github.com/users/IBMStreams/orgs","repos_url":"https://api.github.com/users/IBMStreams/repos","events_url":"https://api.github.com/users/IBMStreams/events{/privacy}","received_events_url":"https://api.github.com/users/IBMStreams/received_events","type":"Organization","site_admin":false},"repo":{"id":36458001,"name":"streamsx.topology","full_name":"IBMStreams/streamsx.topology","owner":{"login":"IBMStreams","id":5439177,"avatar_url":"https://avatars.githubusercontent.com/u/5439177?v=3","gravatar_id":"","url":"https://api.github.com/users/IBMStreams","html_url":"https://github.com/IBMStreams","followers_url":"https://api.github.com/users/IBMStreams/followers","following_url":"https://api.github.com/users/IBMStreams/following{/other_user}","gists_url":"https://api.github.com/users/IBMStreams/gists{/gist_id}","starred_url":"https://api.github.com/users/IBMStreams/starred{/owner}{/repo}","subscriptions_url":"https://api.github.com/users/IBMStreams/subscriptions","organizations_url":"https://api.github.com/users/IBMStreams/orgs","repos_url":"https://api.github.com/users/IBMStreams/repos","events_url":"https://api.github.com/users/IBMStreams/events{/privacy}","received_events_url":"https://api.github.com/users/IBMStreams/received_events","type":"Organization","site_admin":false},"private":false,"html_url":"https://github.com/IBMStreams/streamsx.topology","description":"(Incubation) A project that supports building streaming topologies (applications) for IBM Streams in different programming languages, such as Java, Scala and Python.","fork":false,"url":"https://api.github.com/repos/IBMStreams/streamsx.topology","forks_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/forks","keys_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/keys{/key_id}","collaborators_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/collaborators{/collaborator}","teams_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/teams","hooks_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/hooks","issue_events_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/issues/events{/number}","events_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/events","assignees_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/assignees{/user}","branches_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/branches{/branch}","tags_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/tags","blobs_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/git/blobs{/sha}","git_tags_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/git/tags{/sha}","git_refs_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/git/refs{/sha}","trees_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/git/trees{/sha}","statuses_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/statuses/{sha}","languages_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/languages","stargazers_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/stargazers","contributors_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/contributors","subscribers_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/subscribers","subscription_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/subscription","commits_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/commits{/sha}","git_commits_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/git/commits{/sha}","comments_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/comments{/number}","issue_comment_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/issues/comments{/number}","contents_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/contents/{+path}","compare_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/compare/{base}...{head}","merges_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/merges","archive_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/{archive_format}{/ref}","downloads_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/downloads","issues_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/issues{/number}","pulls_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/pulls{/number}","milestones_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/milestones{/number}","notifications_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/notifications{?since,all,participating}","labels_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/labels{/name}","releases_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/releases{/id}","deployments_url":"https://api.github.com/repos/IBMStreams/streamsx.topology/deployments","created_at":"2015-05-28T18:30:13Z","updated_at":"2016-04-25T16:20:53Z","pushed_at":"2016-05-25T15:46:22Z","git_url":"git://github.com/IBMStreams/streamsx.topology.git","ssh_url":"git@github.com:IBMStreams/streamsx.topology.git","clone_url":"https://github.com/IBMStreams/streamsx.topology.git","svn_url":"https://github.com/IBMStreams/streamsx.topology","homepage":"http://ibmstreams.github.io/streamsx.topology","size":6566,"stargazers_count":10,"watchers_count":10,"language":"Java","has_issues":true,"has_downloads":true,"has_wiki":true,"has_pages":true,"forks_count":17,"mirror_url":null,"open_issues_count":62,"forks":17,"open_issues":62,"watchers":10,"default_branch":"master"}},"_links":{"self":{"href":"https://api.github.com/repos/IBMStreams/streamsx.topology/pulls/396"},"html":{"href":"https://github.com/IBMStreams/streamsx.topology/pull/396"},"issue":{"href":"https://api.github.com/repos/IBMStreams/streamsx.topology/issues/396"},"comments":{"href":"https://api.github.com/repos/IBMStreams/streamsx.topology/issues/396/comments"},"review_comments":{"href":"https://api.github.com/repos/IBMStreams/streamsx.topology/pulls/396/comments"},"review_comment":{"href":"https://api.github.com/repos/IBMStreams/streamsx.topology/pulls/comments{/number}"},"commits":{"href":"https://api.github.com/repos/IBMStreams/streamsx.topology/pulls/396/commits"},"statuses":{"href":"https://api.github.com/repos/IBMStreams/streamsx.topology/statuses/ef90a57dbd84ceffc3fdea2a9452c6068b97c843"}}}}
{"actor":{"display_login":"ddebrunner"}}