• 设为首页
  • 点击收藏
  • 手机版
    手机扫一扫访问
    迪恩网络手机版
  • 关注官方公众号
    微信扫一扫关注
    公众号

Java WebConnector类代码示例

原作者: [db:作者] 来自: [db:来源] 收藏 邀请

本文整理汇总了Java中i5.las2peer.webConnector.WebConnector的典型用法代码示例。如果您正苦于以下问题:Java WebConnector类的具体用法?Java WebConnector怎么用?Java WebConnector使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。



WebConnector类属于i5.las2peer.webConnector包,在下文中一共展示了WebConnector类的7个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: startServer

import i5.las2peer.webConnector.WebConnector; //导入依赖的package包/类
/**
 * Called before the tests start.
 * <p>
 * Sets up the node and initializes connector and users that can be used throughout the tests.
 *
 * @throws Exception
 */
@BeforeClass
public static void startServer() throws Exception {

    // start node
    node = LocalNode.newNode();
    testAgent = MockAgentFactory.getAdam();
    testAgent.unlockPrivateKey(testPass); // agent must be unlocked in order to be stored
    node.storeAgent(testAgent);
    node.launch();

    ServiceAgent testService = ServiceAgent.createServiceAgent(activityTrackerService, "a pass");
    testService.unlockPrivateKey("a pass");

    node.registerReceiver(testService);

    // start connector
    logStream = new ByteArrayOutputStream();

    connector = new WebConnector(true, HTTP_PORT, false, 1000);
    connector.setLogStream(new PrintStream(logStream));
    connector.start(node);
    Thread.sleep(1000); // wait a second for the connector to become ready
    testAgent = MockAgentFactory.getAdam(); // get a locked agent
}
 
开发者ID:rwth-acis,项目名称:las2peer-ActivityTracker,代码行数:32,代码来源:ActivityTrackerTest.java


示例2: startServer

import i5.las2peer.webConnector.WebConnector; //导入依赖的package包/类
/**
 * Called before the tests start.
 * 
 * Sets up the node and initializes connector and users that can be used throughout the tests.
 * 
 * @throws Exception
 */
@BeforeClass
public static void startServer() throws Exception {
	
	//start node
	node = LocalNode.newNode();
	node.storeAgent(MockAgentFactory.getAdam());
	node.launch();
	
	ServiceAgent testService = ServiceAgent.generateNewAgent(testServiceClass, "a pass");
	testService.unlockPrivateKey("a pass");
	
	node.registerReceiver(testService);
	
	//start connector
	logStream = new ByteArrayOutputStream ();
	
	connector = new WebConnector(true,HTTP_PORT,false,1000);
	connector.setSocketTimeout(10000);
	connector.setLogStream(new PrintStream (logStream));
	connector.start ( node );
       Thread.sleep(1000); //wait a second for the connector to become ready
	testAgent = MockAgentFactory.getAdam();
	
       connector.updateServiceList();
       //avoid timing errors: wait for the repository manager to get all services before continuing
       try
       {
           System.out.println("waiting..");
           Thread.sleep(10000);
       }
       catch(InterruptedException e)
       {
           e.printStackTrace();
       }
	
}
 
开发者ID:rwth-acis,项目名称:LAS2peer-AnnotationService,代码行数:44,代码来源:ServiceTest.java


示例3: startServer

import i5.las2peer.webConnector.WebConnector; //导入依赖的package包/类
/**
    * Called before the tests start.
    * 
    * Sets up the node and initializes connector and users that can be used
    * throughout the tests.
    * 
    * @throws Exception
    */
   @BeforeClass
   public static void startServer() throws Exception {

// start node
node = LocalNode.newNode();
node.storeAgent(MockAgentFactory.getAdam());
node.launch();

ServiceAgent testService = ServiceAgent.createServiceAgent(testServiceClass, "a pass");
testService.unlockPrivateKey("a pass");

node.registerReceiver(testService);

// start connector
logStream = new ByteArrayOutputStream();

connector = new WebConnector(true, HTTP_PORT, false, 1000);
connector.setLogStream(new PrintStream(logStream));
connector.start(node);
Thread.sleep(1000); // wait a second for the connector to become ready
testAgent = MockAgentFactory.getAdam();

connector.updateServiceList();
// avoid timing errors: wait for the repository manager to get all
// services before continuing
try {
    System.out.println("waiting..");
    Thread.sleep(10000);
} catch (InterruptedException e) {
    e.printStackTrace();
}

   }
 
开发者ID:learning-layers,项目名称:Expert-Identification-Service,代码行数:42,代码来源:ServiceTest.java


示例4: testSetup

import i5.las2peer.webConnector.WebConnector; //导入依赖的package包/类
@Before
public void testSetup() throws Exception
{

    // start Node
    node = LocalNode.newNode();
    node.storeAgent(MockAgentFactory.getEve());
    node.storeAgent(MockAgentFactory.getAdam());
    node.storeAgent(MockAgentFactory.getAbel());
    node.storeAgent( MockAgentFactory.getGroup1());
    node.launch();

    ServiceAgent testService = ServiceAgent.generateNewAgent(testServiceClass, "a pass");

    testService.unlockPrivateKey("a pass");


    node.registerReceiver(testService);


    // start connector

    logStream = new ByteArrayOutputStream ();

    //String xml=RESTMapper.mergeXMLs(new String[]{RESTMapper.getMethodsAsXML(TestService.class),RESTMapper.getMethodsAsXML(TestService2.class)});
    //System.out.println(xml);
    /*System.out.println(RESTMapper.getMethodsAsXML(TestService.class));
    System.out.println(RESTMapper.getMethodsAsXML(TestService2.class));*/

    connector = new WebConnector(true,HTTP_PORT,false,1000);
    connector.setSocketTimeout(5000);
    connector.setLogStream(new PrintStream ( logStream));
    connector.start ( node );

    // eve is the anonymous agent!
    testAgent = MockAgentFactory.getAdam();

}
 
开发者ID:rwth-acis,项目名称:LAS2peer-iStarMLModel-Service,代码行数:39,代码来源:IStarMLModelServiceRESTTest.java


示例5: startServer

import i5.las2peer.webConnector.WebConnector; //导入依赖的package包/类
/**
    * Called before the tests start.
    * 
    * Sets up the node and initializes connector and users that can be used
    * throughout the tests.
    * 
    * @throws Exception
    */
   @BeforeClass
   public static void startServer() throws Exception {

// start node
node = LocalNode.newNode();
node.storeAgent(MockAgentFactory.getAdam());
node.launch();

ServiceAgent testService = ServiceAgent.generateNewAgent(testServiceClass, "a pass");
testService.unlockPrivateKey("a pass");

node.registerReceiver(testService);

// start connector
logStream = new ByteArrayOutputStream();

connector = new WebConnector(true, HTTP_PORT, false, 1000);
connector.setSocketTimeout(10000);
connector.setLogStream(new PrintStream(logStream));
connector.start(node);
Thread.sleep(1000); // wait a second for the connector to become ready
testAgent = MockAgentFactory.getAdam();

connector.updateServiceList();
// avoid timing errors: wait for the repository manager to get all
// services before continuing
try {
    System.out.println("waiting..");
    Thread.sleep(10000);
} catch (InterruptedException e) {
    e.printStackTrace();
}

   }
 
开发者ID:rwth-acis,项目名称:Expert-Recommender-Service,代码行数:43,代码来源:ServiceTest.java


示例6: startServer

import i5.las2peer.webConnector.WebConnector; //导入依赖的package包/类
/**
 * Called before the tests start.
 * 
 * Sets up the node and initializes connector and users that can be used
 * throughout the tests.
 * 
 * @throws Exception
 */
@BeforeClass
public static void startServer() throws Exception {

	// start node
	node = LocalNode.newNode();
	testAgent = MockAgentFactory.getAdam();
	testAgent.unlockPrivateKey(testPass); // agent must be unlocked in order
											// to be stored
	node.storeAgent(testAgent);
	node.launch();

	// during testing, the specified service version does not matter
	ServiceAgent testService = ServiceAgent
			.createServiceAgent(ServiceNameVersion.fromString(ServiceClass.class.getName() + "@1.0"), "a pass");
	testService.unlockPrivateKey("a pass");

	node.registerReceiver(testService);

	// start connector
	logStream = new ByteArrayOutputStream();

	connector = new WebConnector(true, HTTP_PORT, false, 1000);
	connector.setLogStream(new PrintStream(logStream));
	connector.start(node);
	Thread.sleep(1000); // wait a second for the connector to become ready
	testAgent = MockAgentFactory.getAdam();

	/*
	 * Sets up the database environment for testing.
	 */

	setupDatabase();

}
 
开发者ID:rwth-acis,项目名称:REST-OCD-Services,代码行数:43,代码来源:ServiceTest.java


示例7: startServer

import i5.las2peer.webConnector.WebConnector; //导入依赖的package包/类
/**
 * Called before the tests start.
 * 
 * Sets up the node and initializes connector and users that can be used throughout the tests.
 * 
 * @throws Exception
 */
@BeforeClass
public static void startServer() throws Exception {

	// start node
	node = LocalNode.newNode();
	node.storeAgent(MockAgentFactory.getAdam());
	node.launch();

	ServiceAgent testService = ServiceAgent.generateNewAgent(testServiceClass, "a pass");
	testService.unlockPrivateKey("a pass");

	node.registerReceiver(testService);

	// start connector
	logStream = new ByteArrayOutputStream();

	connector = new WebConnector(true, HTTP_PORT, false, 1000);
	connector.setLogStream(new PrintStream(logStream));
	connector.start(node);
	Thread.sleep(1000); // wait a second for the connector to become ready
	testAgent = MockAgentFactory.getAdam();

	connector.updateServiceList();
	// avoid timing errors: wait for the repository manager to get all services before continuing
	try
	{
		System.out.println("waiting..");
		Thread.sleep(10000);
	} catch (InterruptedException e)
	{
		e.printStackTrace();
	}

}
 
开发者ID:rwth-acis,项目名称:las2peer-FileStorage-Service,代码行数:42,代码来源:DownloadServiceTest.java



注:本文中的i5.las2peer.webConnector.WebConnector类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。


鲜花

握手

雷人

路过

鸡蛋
该文章已有0人参与评论

请发表评论

全部评论

专题导读
上一篇:
Java ExplodeLoop类代码示例发布时间:2022-05-23
下一篇:
Java FindsByTagName类代码示例发布时间:2022-05-23
热门推荐
阅读排行榜

扫描微信二维码

查看手机版网站

随时了解更新最新资讯

139-2527-9053

在线客服(服务时间 9:00~18:00)

在线QQ客服
地址:深圳市南山区西丽大学城创智工业园
电邮:jeky_zhao#qq.com
移动电话:139-2527-9053

Powered by 互联科技 X3.4© 2001-2213 极客世界.|Sitemap