archive/apache-tuscany
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Event prototype: initial sample

Browse source 
git-svn-id: http://svn.us.apache.org/repos/asf/tuscany@705589 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
rsivaram 2008-10-17 12:51:51 +00:00
parent 4628e350ff
commit 0dbacc50af
10 changed files with 449 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

93
sandbox/event/samples/event-jms/pom.xml Normal file
View file

@ -0,0 +1,93 @@
<?xml version="1.0" encoding="UTF-8"?>
<!--
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
-->
<project>
<modelVersion>4.0.0</modelVersion>
<parent>
<groupId>org.apache.tuscany.sca</groupId>
<artifactId>tuscany-sca</artifactId>
<version>1.4-EVENT-SNAPSHOT</version>
<relativePath>../../pom.xml</relativePath>
</parent>
<artifactId>sample-event-jms</artifactId>
<name>Apache Tuscany SCA Event (JMS) Sample</name>
<repositories>
<repository>
<id>apache.incubator</id>
<url>http://people.apache.org/repo/m2-incubating-repository</url>
</repository>
</repositories>
<dependencies>
<dependency>
<groupId>org.apache.tuscany.sca</groupId>
<artifactId>tuscany-host-jetty</artifactId>
<version>1.4-EVENT-SNAPSHOT</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.apache.tuscany.sca</groupId>
<artifactId>tuscany-host-embedded</artifactId>
<version>1.4-EVENT-SNAPSHOT</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>org.apache.tuscany.sca</groupId>
<artifactId>tuscany-implementation-java-runtime</artifactId>
<version>1.4-EVENT-SNAPSHOT</version>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>org.apache.tuscany.sca</groupId>
<artifactId>tuscany-binding-jms</artifactId>
<version>1.4-EVENT-SNAPSHOT</version>
<scope>runtime</scope>
</dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>4.2</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.apache.activemq</groupId>
<artifactId>apache-activemq</artifactId>
<version>4.1.1</version>
<scope>test</scope>
<exclusions>
<exclusion>
<groupId>org.apache.activemq</groupId>
<artifactId>activemq-web-demo</artifactId>
</exclusion>
</exclusions>
</dependency>
</dependencies>
<build>
<finalName>${artifactId}</finalName>
</build>
</project>

25
sandbox/event/samples/event-jms/src/main/java/weather/WeatherPublisher.java Normal file
View file

@ -0,0 +1,25 @@
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*/
package weather;
public interface WeatherPublisher {
void publishWeatherReport(String report);
}

53
sandbox/event/samples/event-jms/src/main/java/weather/WeatherPublisherComponent.java Normal file
View file

@ -0,0 +1,53 @@
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*/
package weather;
import java.util.Date;
import java.util.Random;
import org.osoa.sca.annotations.Producer;
import org.osoa.sca.annotations.Service;
/**
* This class implements the Weather service and publishes weather reports.
*/
@Service(WeatherService.class)
public class WeatherPublisherComponent implements WeatherService {
@Producer
public WeatherPublisher publisher;
public void start() {
try {
for (int i = 0; i < 10; i++) {
generateWeatherReport();
Thread.sleep(1000);
}
} catch (InterruptedException e) {
}
}
public void generateWeatherReport() {
int temperature = new Random().nextInt(20);
String report = "Location: New York, Time: " + new Date() + ", Temperature " + temperature;
publisher.publishWeatherReport(report);
}
}

42
sandbox/event/samples/event-jms/src/main/java/weather/WeatherReporterApp.java Normal file
View file

@ -0,0 +1,42 @@
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*/
package weather;
import org.apache.tuscany.sca.host.embedded.SCADomain;
/**
* This client program shows how to create an SCA runtime, start it,
* locate the Weather service and invoke it.
*/
public class WeatherReporterApp {
public final static void main(String[] args) throws Exception {
SCADomain weatherPublisherDomain = SCADomain.newInstance("weatherPublisher.composite");
SCADomain weatherSubscriberDomain = SCADomain.newInstance("weatherSubscriber.composite");
WeatherService weatherService = weatherPublisherDomain.getService(WeatherService.class, "WeatherPublisherComponent");
weatherService.start();
weatherPublisherDomain.close();
weatherSubscriberDomain.close();
}
}

29
sandbox/event/samples/event-jms/src/main/java/weather/WeatherService.java Normal file
View file

@ -0,0 +1,29 @@
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*/
package weather;
import org.osoa.sca.annotations.Remotable;
/**
* The interface for the weather service
*/
@Remotable
public interface WeatherService {
public void start();
}

38
sandbox/event/samples/event-jms/src/main/java/weather/WeatherSubscriberComponent.java Normal file
View file

@ -0,0 +1,38 @@
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*/
package weather;
import java.util.Date;
import org.osoa.sca.annotations.Consumer;
/**
* The WeatherService subscriber implementation - receives weather reports and prints it on stdout
*/
public class WeatherSubscriberComponent {
@Consumer(name="weatherSubscriber")
public void onWeather(String report) {
System.out.println("Weather report received at " + new Date() + ": " + report);
}
}

30
sandbox/event/samples/event-jms/src/main/resources/logging.properties Normal file
View file

@ -0,0 +1,30 @@
# Licensed to the Apache Software Foundation (ASF) under one
# or more contributor license agreements. See the NOTICE file
# distributed with this work for additional information
# regarding copyright ownership. The ASF licenses this file
# to you under the Apache License, Version 2.0 (the
# "License"); you may not use this file except in compliance
# with the License. You may obtain a copy of the License at
#
# http://www.apache.org/licenses/LICENSE-2.0
#
# Unless required by applicable law or agreed to in writing,
# software distributed under the License is distributed on an
# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
# KIND, either express or implied. See the License for the
# specific language governing permissions and limitations
# under the License.
#
# $Rev$ $Date$
#
# Custom logging configuration for Tuscany samples
# By default, only INFO level logging is enabled and ALL messages get sent to the console
# For more messages from the runtime, uncomment specific settings at the end of this file
handlers = java.util.logging.ConsoleHandler
java.util.logging.ConsoleHandler.level = ALL
java.util.logging.ConsoleHandler.formatter = java.util.logging.SimpleFormatter
.level=INFO
# Uncomment the next setting to get all Tuscany messages (this will be a lot)
#org.apache.tuscany.level=FINEST

38
sandbox/event/samples/event-jms/src/main/resources/weatherPublisher.composite Normal file
View file

@ -0,0 +1,38 @@
<?xml version="1.0" encoding="UTF-8"?>
<!--
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
-->
<composite xmlns="http://www.osoa.org/xmlns/sca/1.0"
xmlns:tuscany="http://tuscany.apache.org/xmlns/sca/1.0"
targetNamespace="http://weather"
xmlns:weather="http://weather"
name="weatherPublisher">
<component name="WeatherPublisherComponent">
<implementation.java class="weather.WeatherPublisherComponent" />
<service name="WeatherService">
<interface.java interface="weather.WeatherService"/>
</service>
<producer name="weatherPublisher">
</producer>
</component>
</composite>

35
sandbox/event/samples/event-jms/src/main/resources/weatherSubscriber.composite Normal file
View file

@ -0,0 +1,35 @@
<?xml version="1.0" encoding="UTF-8"?>
<!--
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
-->
<composite xmlns="http://www.osoa.org/xmlns/sca/1.0"
xmlns:tuscany="http://tuscany.apache.org/xmlns/sca/1.0"
targetNamespace="http://weather"
xmlns:weather="http://weather"
name="weatherSubscriber">
<component name="WeatherSubscriberComponent">
<implementation.java class="weather.WeatherSubscriberComponent"/>
<consumer name="weatherSubscriber">
</consumer>
</component>
</composite>

66
sandbox/event/samples/event-jms/src/test/java/weather/WeatherTestCase.java Normal file
View file

@ -0,0 +1,66 @@
/*
* Licensed to the Apache Software Foundation (ASF) under one
* or more contributor license agreements. See the NOTICE file
* distributed with this work for additional information
* regarding copyright ownership. The ASF licenses this file
* to you under the Apache License, Version 2.0 (the
* "License"); you may not use this file except in compliance
* with the License. You may obtain a copy of the License at
*
* http://www.apache.org/licenses/LICENSE-2.0
*
* Unless required by applicable law or agreed to in writing,
* software distributed under the License is distributed on an
* "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
* KIND, either express or implied. See the License for the
* specific language governing permissions and limitations
* under the License.
*/
package weather;
import org.apache.tuscany.sca.host.embedded.SCADomain;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;
import weather.WeatherService;
/**
* Test case for Tempore weather client
*/
public class WeatherTestCase {
private WeatherService weatherService;
private SCADomain weatherSubscriberDomain;
private SCADomain weatherPublisherDomain;
@Before
public void startClient() throws Exception {
try {
weatherPublisherDomain = SCADomain.newInstance("weatherPublisher.composite");
weatherSubscriberDomain = SCADomain.newInstance("weatherSubscriber.composite");
weatherService = weatherPublisherDomain.getService(WeatherService.class, "WeatherPublisherComponent");
} catch (Throwable e) {
e.printStackTrace();
}
}
@Test
public void testClient() throws Exception {
weatherService.start();
}
@After
public void stopClient() throws Exception {
weatherPublisherDomain.close();
weatherSubscriberDomain.close();
}
}