开通博客赚积分
发布资源赚积分
分类

源码开发语言/平台
当前位置：首页 > 源码/资料 > 中间件编程 > 查看源码
RunServer.java
资源名称：blacktie-2.0.0.M3-src.zip　[点击查看]
上传用户：xfwatch
上传日期：2020-12-14
资源大小：872k
文件大小：10k
源码类别：

中间件编程

开发平台：

Java

RunServer.java：源码内容
  1. /*
  2.  * JBoss, Home of Professional Open Source
  3.  * Copyright 2008, Red Hat, Inc., and others contributors as indicated
  4.  * by the @authors tag. All rights reserved.
  5.  * See the copyright.txt in the distribution for a
  6.  * full listing of individual contributors.
  7.  * This copyrighted material is made available to anyone wishing to use,
  8.  * modify, copy, or redistribute it subject to the terms and conditions
  9.  * of the GNU Lesser General Public License, v. 2.1.
  10.  * This program is distributed in the hope that it will be useful, but WITHOUT A
  11.  * WARRANTY; without even the implied warranty of MERCHANTABILITY or FITNESS FOR A
  12.  * PARTICULAR PURPOSE.  See the GNU Lesser General Public License for more details.
  13.  * You should have received a copy of the GNU Lesser General Public License,
  14.  * v.2.1 along with this distribution; if not, write to the Free Software
  15.  * Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston,
  16.  * MA  02110-1301, USA.
  17.  */
  18. package org.jboss.blacktie.jatmibroker;
  20. import org.jboss.blacktie.jatmibroker.core.conf.ConfigurationException;
  21. import org.jboss.blacktie.jatmibroker.core.server.AtmiBrokerServer;
  22. import org.jboss.blacktie.jatmibroker.tx.TestRollbackOnlyNoTpreturnService;
  23. import org.jboss.blacktie.jatmibroker.tx.TestRollbackOnlyTpcallTPEOTYPEService;
  24. import org.jboss.blacktie.jatmibroker.tx.TestRollbackOnlyTpcallTPESVCFAILService;
  25. import org.jboss.blacktie.jatmibroker.tx.TestRollbackOnlyTpcallTPETIMEService;
  26. import org.jboss.blacktie.jatmibroker.tx.TestRollbackOnlyTprecvTPEVDISCONIMMService;
  27. import org.jboss.blacktie.jatmibroker.tx.TestRollbackOnlyTprecvTPEVSVCFAILService;
  28. import org.jboss.blacktie.jatmibroker.xatmi.ConnectionException;
  29. import org.jboss.blacktie.jatmibroker.xatmi.TestSpecExampleOneService;
  30. import org.jboss.blacktie.jatmibroker.xatmi.TestSpecExampleTwoService;
  31. import org.jboss.blacktie.jatmibroker.xatmi.TestTPACallService;
  32. import org.jboss.blacktie.jatmibroker.xatmi.TestTPCallServiceXCType;
  33. import org.jboss.blacktie.jatmibroker.xatmi.TestTPCallServiceXCommon;
  34. import org.jboss.blacktie.jatmibroker.xatmi.TestTPCallServiceXOctet;
  35. import org.jboss.blacktie.jatmibroker.xatmi.TestTPCancelService;
  36. import org.jboss.blacktie.jatmibroker.xatmi.TestTPConnectService;
  37. import org.jboss.blacktie.jatmibroker.xatmi.TestTPConversationService;
  38. import org.jboss.blacktie.jatmibroker.xatmi.TestTPConversationServiceShort;
  39. import org.jboss.blacktie.jatmibroker.xatmi.TestTPDisconService;
  40. import org.jboss.blacktie.jatmibroker.xatmi.TestTPGetRplyService;
  41. import org.jboss.blacktie.jatmibroker.xatmi.TestTPRecvService;
  42. import org.jboss.blacktie.jatmibroker.xatmi.TestTPReturnService;
  43. import org.jboss.blacktie.jatmibroker.xatmi.TestTPReturnServiceTpurcode;
  44. import org.jboss.blacktie.jatmibroker.xatmi.TestTPSendService;
  45. import org.jboss.blacktie.jatmibroker.xatmi.TestTPSendTPSendOnlyService;
  46. import org.jboss.blacktie.jatmibroker.xatmi.TestTPServiceService;
  47. import org.jboss.blacktie.jatmibroker.xatmi.TestTTLService;
  49. public class RunServer {
  51. private AtmiBrokerServer server;
  53. public void serverinit() throws ConfigurationException, ConnectionException {
  54. this.server = new AtmiBrokerServer("standalone-server");
  55. }
  57. public void serverdone() throws ConnectionException {
  58. server.close();
  59. }
  61. public void tpadvertiseBAR() {
  62. }
  64. public void tpadvertiseLOOPY() {
  65. }
  67. public void tpadvertiseDEBIT() throws ConnectionException {
  68. this.server.tpadvertise("TestOne", TestSpecExampleOneService.class
  69. .getName());
  70. }
  72. public void tpadvertiseCREDIT() throws ConnectionException {
  73. this.server.tpadvertise("TestTwo", TestSpecExampleOneService.class
  74. .getName());
  75. }
  77. public void tpadvertiseINQUIRY() throws ConnectionException {
  78. this.server.tpadvertise("TestOne", TestSpecExampleTwoService.class
  79. .getName());
  80. }
  82. public void tpadvertiseTestTPACall() throws ConnectionException {
  83. this.server.tpadvertise("TestOne", TestTPACallService.class.getName());
  84. }
  86. public void tpadvertisetpcallXOctet() throws ConnectionException {
  87. this.server.tpadvertise("TestOne", TestTPCallServiceXOctet.class
  88. .getName());
  89. }
  91. public void tpadvertisetpcallXOctetZero() throws ConnectionException {
  92. }
  94. public void tpadvertisetpcallXCommon() throws ConnectionException {
  95. this.server.tpadvertise("TestOne", TestTPCallServiceXCommon.class
  96. .getName());
  97. }
  99. public void tpadvertisetpcallXCType() throws ConnectionException {
  100. this.server.tpadvertise("TestOne", TestTPCallServiceXCType.class
  101. .getName());
  102. }
  104. public void tpadvertiseTestTPCancel() throws ConnectionException {
  105. this.server.tpadvertise("TestOne", TestTPCancelService.class.getName());
  106. }
  108. public void tpadvertiseTestTPConnect() throws ConnectionException {
  109. this.server
  110. .tpadvertise("TestOne", TestTPConnectService.class.getName());
  111. }
  113. public void tpadvertiseTestTPConversation() throws ConnectionException {
  114. this.server.tpadvertise("TestOne", TestTPConversationService.class
  115. .getName());
  116. }
  118. public void tpadvertiseTestTPConversa2() throws ConnectionException {
  119. this.server.tpadvertise("TestOne", TestTPConversationServiceShort.class
  120. .getName());
  121. }
  123. public void tpadvertiseTestTPDiscon() throws ConnectionException {
  124. this.server.tpadvertise("TestOne", TestTPDisconService.class.getName());
  125. }
  127. public void tpadvertiseTestTPFree() throws ConnectionException {
  128. }
  130. public void tpadvertiseTestTPGetrply() throws ConnectionException {
  131. this.server
  132. .tpadvertise("TestOne", TestTPGetRplyService.class.getName());
  133. }
  135. public void tpadvertiseTestTPRecv() throws ConnectionException {
  136. this.server.tpadvertise("TestOne", TestTPRecvService.class.getName());
  137. }
  139. public void tpadvertiseTestTPReturn() throws ConnectionException {
  140. this.server.tpadvertise("TestOne", TestTPReturnService.class.getName());
  141. }
  143. public void tpadvertiseTestTPReturn2() throws ConnectionException {
  144. this.server.tpadvertise("TestOne", TestTPReturnServiceTpurcode.class
  145. .getName());
  146. }
  148. public void tpadvertiseTestTPSend() throws ConnectionException {
  149. this.server.tpadvertise("TestOne", TestTPSendService.class.getName());
  150. }
  152. public void tpadvertiseTestTPSendTPSendOnly() throws ConnectionException {
  153. this.server.tpadvertise("TestOne", TestTPSendTPSendOnlyService.class
  154. .getName());
  155. }
  157. public void tpadvertiseTestTPService() throws ConnectionException {
  158. this.server
  159. .tpadvertise("TestOne", TestTPServiceService.class.getName());
  160. }
  162. public void tpadvertiseTestTPUnadvertise() throws ConnectionException {
  163. }
  165. public void tpadvertiseTX1() throws ConnectionException {
  166. }
  168. public void tpadvertiseTX2() throws ConnectionException {
  169. }
  171. public void tpadvertiseTTL() throws ConnectionException {
  172. this.server.tpadvertise("TestOne", TestTTLService.class.getName());
  173. }
  175. // SERVICE NAMES
  176. public String getServiceNameBAR() {
  177. throw new RuntimeException("NOT IMPLEMENTED");
  178. }
  180. public String getServiceNameLOOPY() {
  181. throw new RuntimeException("NOT IMPLEMENTED");
  182. }
  184. public String getServiceNameDEBIT() {
  185. return "TestOne";
  186. }
  188. public String getServiceNameCREDIT() {
  189. return "TestTwo";
  190. }
  192. public String getServiceNameINQUIRY() {
  193. return "TestOne";
  194. }
  196. public String getServiceNameTestTPACall() {
  197. return "TestOne";
  198. }
  200. public String getServiceNametpcallXOctet() {
  201. return "TestOne";
  202. }
  204. public String getServiceNametpcallXOctetZero() {
  205. throw new RuntimeException("NOT IMPLEMENTED");
  206. }
  208. public String getServiceNametpcallXCommon() {
  209. return "TestOne";
  210. }
  212. public String getServiceNametpcallXCType() {
  213. return "TestOne";
  214. }
  216. public String getServiceNameTestTPCancel() {
  217. return "TestOne";
  218. }
  220. public String getServiceNameTestTPConnect() {
  221. return "TestOne";
  222. }
  224. public String getServiceNameTestTPConversation() {
  225. return "TestOne";
  226. }
  228. public String getServiceNameTestTPDiscon() {
  229. return "TestOne";
  230. }
  232. public String getServiceNameTestTPConversa2() {
  233. return "TestOne";
  234. }
  236. public String getServiceNameTestTPFree() {
  237. throw new RuntimeException("NOT SUPPORTED");
  238. }
  240. public String getServiceNameTestTPGetrply() {
  241. return "TestOne";
  242. }
  244. public String getServiceNameTestTPRecv() {
  245. return "TestOne";
  246. }
  248. public String getServiceNameTestTPReturn() {
  249. return "TestOne";
  250. }
  252. public String getServiceNameTestTPReturn2() {
  253. return "TestOne";
  254. }
  256. public String getServiceNameTestTPSend() {
  257. return "TestOne";
  258. }
  260. public String getServiceNameTestTPSendTPSendOnly() {
  261. return "TestOne";
  262. }
  264. public String getServiceNameTestTPService() {
  265. return "TestOne";
  266. }
  268. public String getServiceNameTestTPUnadvertise() {
  269. throw new RuntimeException("NOT SUPPORTED");
  270. }
  272. public String getServiceNameTX1() {
  273. throw new RuntimeException("NOT SUPPORTED");
  274. }
  276. public String getServiceNameTX2() {
  277. throw new RuntimeException("NOT SUPPORTED");
  278. }
  280. public String getServiceNameTTL() {
  281. return "TestOne";
  282. }
  284. public String getServiceNameTestRollbackOnly() {
  285. return "TestOne";
  286. // return "TestRbkOnly";
  287. }
  289. public void tpadvertiseTestRollbackOnlyTpcallTPETIMEService()
  290. throws ConnectionException {
  291. this.server.tpadvertise(getServiceNameTestRollbackOnly(),
  292. TestRollbackOnlyTpcallTPETIMEService.class.getName());
  293. }
  295. public void tpadvertiseTestTpcallTPEOTYPEService()
  296. throws ConnectionException {
  297. this.server.tpadvertise(getServiceNameTestRollbackOnly(),
  298. TestRollbackOnlyTpcallTPEOTYPEService.class.getName());
  300. }
  302. public void tpadvertiseTestRollbackOnlyTpcallTPESVCFAILService()
  303. throws ConnectionException {
  304. this.server.tpadvertise(getServiceNameTestRollbackOnly(),
  305. TestRollbackOnlyTpcallTPESVCFAILService.class.getName());
  306. }
  308. public void tpadvertiseTestRollbackOnlyTprecvTPEVDISCONIMMService()
  309. throws ConnectionException {
  310. this.server.tpadvertise(getServiceNameTestRollbackOnly(),
  311. TestRollbackOnlyTprecvTPEVDISCONIMMService.class.getName());
  312. }
  314. public void tpadvertiseTestRollbackOnlyTprecvTPEVSVCFAILService()
  315. throws ConnectionException {
  316. this.server.tpadvertise(getServiceNameTestRollbackOnly(),
  317. TestRollbackOnlyTprecvTPEVSVCFAILService.class.getName());
  318. }
  320. public void tpadvertiseTestRollbackOnlyNoTpreturnService()
  321. throws ConnectionException {
  322. this.server.tpadvertise(getServiceNameTestRollbackOnly(),
  323. TestRollbackOnlyNoTpreturnService.class.getName());
  324. }
  325. }