本文整理汇总了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;未经允许,请勿转载。 |
请发表评论