2025

2024

2023

2022

2021

2020

2019

2018

2017

2016

2015

2014

2013

2012

2011

2010

2009

2008

seam-commits May 2010

seam-commits@lists.jboss.org

1 participants
245 discussions

Start a nNew thread

Seam SVN: r12675 - in modules/jms/branches/simple-forwarding: api/src/main/java/org/jboss/seam/jms/annotations and 7 other directories.

by seam-commits＠lists.jboss.org

Author: jganoff Date: 2010-04-30 22:33:09 -0400 (Fri, 30 Apr 2010) New Revision: 12675 Modified: modules/jms/branches/simple-forwarding/api/src/main/java/org/jboss/seam/jms/annotations/JmsDestination.java modules/jms/branches/simple-forwarding/api/src/main/java/org/jboss/seam/jms/annotations/JmsSession.java modules/jms/branches/simple-forwarding/api/src/main/java/org/jboss/seam/jms/annotations/Module.java modules/jms/branches/simple-forwarding/docs/reference/src/main/docbook/en-US/… [View More]

14 years, 10 months

1
0
0 / 0

Seam SVN: r12674 - modules/jms/trunk.

by seam-commits＠lists.jboss.org

Author: jganoff Date: 2010-04-30 21:58:25 -0400 (Fri, 30 Apr 2010) New Revision: 12674 Modified: modules/jms/trunk/pom.xml Log: [maven-release-plugin] rollback the release of 3.0.0.Alpha1 Modified: modules/jms/trunk/pom.xml =================================================================== --- modules/jms/trunk/pom.xml 2010-05-01 01:18:35 UTC (rev 12673) +++ modules/jms/trunk/pom.xml 2010-05-01 01:58:25 UTC (rev 12674) @@ -4,9 +4,9 @@ <modelVersion>4.0.0</modelVersion> … [View More]

14 years, 10 months

1
0
0 / 0

Seam SVN: r12673 - modules/international/trunk.

by seam-commits＠lists.jboss.org

Author: kenfinni Date: 2010-04-30 21:18:35 -0400 (Fri, 30 Apr 2010) New Revision: 12673 Modified: modules/international/trunk/pom.xml Log: SEAMINTL-1 - Forgot to commit latest module pom! Modified: modules/international/trunk/pom.xml =================================================================== --- modules/international/trunk/pom.xml 2010-05-01 01:05:28 UTC (rev 12672) +++ modules/international/trunk/pom.xml 2010-05-01 01:18:35 UTC (rev 12673) @@ -1,113 +1,145 @@ <project xmlns="… [View More]http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" - xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd"> - <modelVersion>4.0.0</modelVersion> + xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd"> + <modelVersion>4.0.0</modelVersion> - <parent> - <artifactId>seam-parent</artifactId> - <groupId>org.jboss.seam</groupId> - <version>3.0.0-SNAPSHOT</version> - </parent> + <parent> + <groupId>org.jboss.weld</groupId> + <artifactId>weld-parent</artifactId> + <version>9</version> + </parent> - <artifactId>seam-international-parent</artifactId> - <groupId>org.jboss.seam.international</groupId> - <version>3.0.0-SNAPSHOT</version> + <artifactId>seam-international-parent</artifactId> + <groupId>org.jboss.seam.international</groupId> + <version>3.0.0-SNAPSHOT</version> - <packaging>pom</packaging> - <name>Seam International Module Parent POM</name> + <packaging>pom</packaging> + <name>Seam International Module Parent POM</name> - <description>The Parent for Seam International Module</description> - <url>http://www.seamframework.org</url> + <description>The Parent for Seam International Module</description> + <url>http://www.seamframework.org</url> - <modules> - <module>api</module> - <module>impl</module> -  -  - </modules> + <modules> + <module>api</module> + <module>impl</module> +  +  + </modules> - <properties> - <arquillian.version>1.0.0.Alpha1</arquillian.version> - </properties> + <properties> + <arquillian.version>1.0.0.Alpha1</arquillian.version> + <seam.xml.version>3.0.0-SNAPSHOT</seam.xml.version> + <weld.extensions.version>1.0.0.Alpha1</weld.extensions.version> + <weld.api.version>1.0-SP1</weld.api.version> + <joda-time.version>1.6</joda-time.version> + <pretty-time.version>1.0.6</pretty-time.version> + </properties> - <dependencies> + <dependencyManagement> + <dependencies> + <dependency> + <groupId>org.jboss.weld</groupId> + <artifactId>weld-api-bom</artifactId> + <version>${weld.api.version}</version> + <scope>import</scope> + <type>pom</type> + </dependency> + </dependencies> + </dependencyManagement> -  - <dependency> - <groupId>javax.el</groupId> - <artifactId>el-api</artifactId> - <version>2.2</version> - <scope>provided</scope> - </dependency> - <dependency> - <groupId>javax.enterprise</groupId> - <artifactId>cdi-api</artifactId> - <scope>provided</scope> - </dependency> - <dependency> - <groupId>org.jboss.weld</groupId> - <artifactId>weld-extensions</artifactId> - <version>1.0.0.Alpha1</version> - </dependency> + <dependencies> -  - <dependency> - <groupId>junit</groupId> - <artifactId>junit</artifactId> - <version>4.8.1</version> - <scope>test</scope> - </dependency> - <dependency> - <groupId>org.jboss.arquillian</groupId> - <artifactId>arquillian-junit</artifactId> - <version>${arquillian.version}</version> - <scope>test</scope> - </dependency> - <dependency> - <groupId>org.jboss.arquillian.container</groupId> - <artifactId>arquillian-weld-embedded</artifactId> - <version>${arquillian.version}</version> - <scope>test</scope> - </dependency> - </dependencies> +  + <dependency> + <groupId>javax.el</groupId> + <artifactId>el-api</artifactId> + <version>2.2</version> + <scope>provided</scope> + </dependency> + <dependency> + <groupId>javax.enterprise</groupId> + <artifactId>cdi-api</artifactId> + <scope>provided</scope> + </dependency> + <dependency> + <groupId>org.jboss.weld</groupId> + <artifactId>weld-extensions</artifactId> + <version>${weld.extensions.version}</version> + </dependency> + <dependency> + <groupId>joda-time</groupId> + <artifactId>joda-time</artifactId> + <version>${joda-time.version}</version> + </dependency> + <dependency> + <groupId>com.ocpsoft</groupId> + <artifactId>ocpsoft-pretty-time</artifactId> + <version>${pretty-time.version}</version> + </dependency> - <developers> - <developer> - <name>Lincoln Baxter, III</name> - <email>lincolnbaxter(a)gmail.com</email> - <url>http://ocpsoft.com</url> - <organization>JBoss, by Red Hat</organization> - <organizationUrl>http://jboss.org</organizationUrl> - <timezone>EST</timezone> - <roles> - <role>Project Lead</role> - </roles> - </developer> - <developer> - <name>Ken Finnigan</name> - <timezone>GMT</timezone> - <roles> - <role>Project Lead</role> - </roles> - </developer> - </developers> +  + <dependency> + <groupId>junit</groupId> + <artifactId>junit</artifactId> + <version>4.8.1</version> + <scope>test</scope> + </dependency> + <dependency> + <groupId>org.jboss.arquillian</groupId> + <artifactId>arquillian-junit</artifactId> + <version>${arquillian.version}</version> + <scope>test</scope> + </dependency> + <dependency> + <groupId>org.jboss.arquillian.container</groupId> + <artifactId>arquillian-weld-embedded</artifactId> + <version>${arquillian.version}</version> + <scope>test</scope> + </dependency> + <dependency> + <groupId>org.jboss.seam.xml</groupId> + <artifactId>seam-xml-bean-config</artifactId> + <version>${seam.xml.version}</version> + </dependency> + </dependencies> - <scm> - <connection>scm:svn:http://anonsvn.jboss.org/repos/seam/modules/international/trunk</connection> - <developerConnection>scm:svn:https://svn.jboss.org/repos/seam/modules/international/trunk</developerConnection> - <url>http://fisheye.jboss.org/browse/Seam/modules/international/trunk</url> - </scm> + <developers> + <developer> + <name>Lincoln Baxter, III</name> + <email>lincolnbaxter(a)gmail.com</email> + <url>http://ocpsoft.com</url> + <organization>JBoss, by Red Hat</organization> + <organizationUrl>http://jboss.org</organizationUrl> + <timezone>EST</timezone> + <roles> + <role>Project Lead</role> + </roles> + </developer> + <developer> + <name>Ken Finnigan</name> + <timezone>GMT</timezone> + <roles> + <role>Project Lead</role> + </roles> + </developer> + </developers> - <build> - <plugins> - <plugin> - <groupId>org.apache.maven.plugins</groupId> - <artifactId>maven-compiler-plugin</artifactId> - <version>2.0.2</version> - <configuration> - <source>1.5</source> - <target>1.5</target> - </configuration> - </plugin> - </plugins> - </build> + <scm> + <connection>scm:svn:http://anonsvn.jboss.org/repos/seam/modules/international/trunk</connection> + <developerConnection>scm:svn:https://svn.jboss.org/repos/seam/modules/international/trunk</developerConnection> + <url>http://fisheye.jboss.org/browse/Seam/modules/international/trunk</url> + </scm> + + <build> + <plugins> + <plugin> + <groupId>org.apache.maven.plugins</groupId> + <artifactId>maven-compiler-plugin</artifactId> + <version>2.0.2</version> + <configuration> + <source>1.5</source> + <target>1.5</target> + </configuration> + </plugin> + </plugins> + </build> </project> [View Less]

14 years, 10 months

1
0
0 / 0

Seam SVN: r12672 - in modules/jms/trunk: docs/reference/src/main/docbook/en-US and 6 other directories.

by seam-commits＠lists.jboss.org

Author: jganoff Date: 2010-04-30 21:05:28 -0400 (Fri, 30 Apr 2010) New Revision: 12672 Modified: modules/jms/trunk/api/src/main/java/org/jboss/seam/jms/annotations/JmsDestination.java modules/jms/trunk/api/src/main/java/org/jboss/seam/jms/annotations/JmsSession.java modules/jms/trunk/api/src/main/java/org/jboss/seam/jms/annotations/Module.java modules/jms/trunk/docs/reference/src/main/docbook/en-US/author_group.xml modules/jms/trunk/docs/reference/src/main/docbook/en-US/… [View More]

14 years, 10 months

1
0
0 / 0

Seam SVN: r12671 - in modules/jms/branches: simple-forwarding/api/src/main/java/org/jboss/seam/jms/annotations and 4 other directories.

by seam-commits＠lists.jboss.org

Author: jganoff Date: 2010-04-30 20:35:52 -0400 (Fri, 30 Apr 2010) New Revision: 12671 Added: modules/jms/branches/simple-forwarding/ modules/jms/branches/simple-forwarding/api/src/main/java/org/jboss/seam/jms/annotations/Bridged.java modules/jms/branches/simple-forwarding/impl/src/main/java/org/jboss/seam/jms/BridgedObserver.java modules/jms/branches/simple-forwarding/impl/src/test/java/org/jboss/seam/jms/test/bridge/ modules/jms/branches/simple-forwarding/impl/src/test/java/… [View More]org/jboss/seam/jms/test/bridge/simple/ modules/jms/branches/simple-forwarding/impl/src/test/java/org/jboss/seam/jms/test/bridge/simple/MyTopic.java modules/jms/branches/simple-forwarding/impl/src/test/java/org/jboss/seam/jms/test/bridge/simple/SimpleBridgedEventTest.java Modified: modules/jms/branches/simple-forwarding/impl/src/main/java/org/jboss/seam/jms/Seam3JmsExtension.java Log: Initial ideas on simple event forwarding Copied: modules/jms/branches/simple-forwarding (from rev 12664, modules/jms/trunk) Added: modules/jms/branches/simple-forwarding/api/src/main/java/org/jboss/seam/jms/annotations/Bridged.java =================================================================== --- modules/jms/branches/simple-forwarding/api/src/main/java/org/jboss/seam/jms/annotations/Bridged.java (rev 0) +++ modules/jms/branches/simple-forwarding/api/src/main/java/org/jboss/seam/jms/annotations/Bridged.java 2010-05-01 00:35:52 UTC (rev 12671) @@ -0,0 +1,28 @@ +package org.jboss.seam.jms.annotations; + +import static java.lang.annotation.ElementType.FIELD; +import static java.lang.annotation.ElementType.METHOD; +import static java.lang.annotation.ElementType.PARAMETER; +import static java.lang.annotation.ElementType.TYPE; +import static java.lang.annotation.RetentionPolicy.RUNTIME; + +import java.lang.annotation.Documented; +import java.lang.annotation.Inherited; +import java.lang.annotation.Retention; +import java.lang.annotation.Target; + +import javax.inject.Qualifier; + +/** + * Bridged Event + * + * @author Jordan Ganoff + */ +@Qualifier +@Documented +@Inherited +@Target( { FIELD, METHOD, TYPE, PARAMETER }) +@Retention(RUNTIME) +public @interface Bridged +{ +} \ No newline at end of file Added: modules/jms/branches/simple-forwarding/impl/src/main/java/org/jboss/seam/jms/BridgedObserver.java =================================================================== --- modules/jms/branches/simple-forwarding/impl/src/main/java/org/jboss/seam/jms/BridgedObserver.java (rev 0) +++ modules/jms/branches/simple-forwarding/impl/src/main/java/org/jboss/seam/jms/BridgedObserver.java 2010-05-01 00:35:52 UTC (rev 12671) @@ -0,0 +1,108 @@ +package org.jboss.seam.jms; + +import java.io.Serializable; +import java.lang.annotation.Annotation; +import java.lang.reflect.Type; +import java.util.Collections; +import java.util.Set; + +import javax.enterprise.event.Reception; +import javax.enterprise.event.TransactionPhase; +import javax.enterprise.inject.spi.Bean; +import javax.enterprise.inject.spi.BeanManager; +import javax.enterprise.inject.spi.ObserverMethod; +import javax.enterprise.util.AnnotationLiteral; +import javax.jms.Destination; +import javax.jms.JMSException; +import javax.jms.Message; +import javax.jms.Session; + +import org.jboss.seam.jms.annotations.Bridged; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; + +/** + * Observer Method to observe events and forward (bridge) them over JMS. + * + * @author Jordan Ganoff + */ +public class BridgedObserver implements ObserverMethod<Object> +{ + private Logger log = LoggerFactory.getLogger(getClass()); + + private static final Set<Annotation> BRIDGED = Collections.<Annotation> singleton(new AnnotationLiteral<Bridged>() + { + private static final long serialVersionUID = 1L; + }); + + private BeanManager bm; + private Destination destination; + private Set<Annotation> qualifiers; + + public BridgedObserver(BeanManager bm) + { + this.bm = bm; + } + + public Class<?> getBeanClass() + { + return null; + } + + public Set<Annotation> getObservedQualifiers() + { + // Note, annotation MUST be @Qualifier. No error given but will not work! + return BRIDGED; + } + + public Type getObservedType() + { + return Object.class; + } + + public Reception getReception() + { + return Reception.ALWAYS; + } + + public TransactionPhase getTransactionPhase() + { + return TransactionPhase.AFTER_SUCCESS; + } + + public void notify(Object evt) + { + // FIXME Include qualifiers once CDI 1.0 MR is complete and + // notify(Event, Set<Annotation>) is added + forwardEvent(evt, null); + } + + private void forwardEvent(Object event, Set<Annotation> qualifiers) + { + log.info("Forwarding event {}", event); + // p.forwardEvent(event, qualifiers); + + // for (EventPropagator p : ServiceLoader.load(EventPropagator.class)) + // { + // p.forwardEvent(event, null); + // } + + try + { + Set<Bean<?>> beans = bm.getBeans(Session.class);// , new + // AnnotationLiteral<org.jboss.seam.jms.annotations.Session>() + // {}); + Bean<?> bean = bm.resolve(beans); + Session s = (Session) bm.getReference(bean, Session.class, bm.createCreationalContext(bean)); + log.info("Forwarding with session {}", s); + log.info("To destination {}", destination); + Message m = s.createObjectMessage((Serializable) event); + s.createProducer(destination).send(m); + s.close(); + } + catch (JMSException ex) + { + log.error("Unable to forward event", ex); + } + } +} Modified: modules/jms/branches/simple-forwarding/impl/src/main/java/org/jboss/seam/jms/Seam3JmsExtension.java =================================================================== --- modules/jms/trunk/impl/src/main/java/org/jboss/seam/jms/Seam3JmsExtension.java 2010-04-29 20:57:43 UTC (rev 12664) +++ modules/jms/branches/simple-forwarding/impl/src/main/java/org/jboss/seam/jms/Seam3JmsExtension.java 2010-05-01 00:35:52 UTC (rev 12671) @@ -1,6 +1,8 @@ package org.jboss.seam.jms; import javax.enterprise.event.Observes; +import javax.enterprise.inject.spi.AfterBeanDiscovery; +import javax.enterprise.inject.spi.BeanManager; import javax.enterprise.inject.spi.Extension; import javax.enterprise.inject.spi.ProcessAnnotatedType; @@ -13,8 +15,18 @@ */ public class Seam3JmsExtension implements Extension { + public void afterBeanDiscovery(@Observes AfterBeanDiscovery abd, BeanManager bm) + { + // Temporary creation of bridged overserver (This should be changed to allow configuration from XML) + BridgedObserver b = new BridgedObserver(bm); + abd.addObserverMethod(b); + } + public <X> void decorateAnnotatedType(@Observes ProcessAnnotatedType<X> pat) { + /** + * Flatten all @Annotated that define @JmsDestinations so that they may be injected + */ pat.setAnnotatedType(JmsAnnotatedTypeWrapper.decorate(pat.getAnnotatedType())); } } Added: modules/jms/branches/simple-forwarding/impl/src/test/java/org/jboss/seam/jms/test/bridge/simple/MyTopic.java =================================================================== --- modules/jms/branches/simple-forwarding/impl/src/test/java/org/jboss/seam/jms/test/bridge/simple/MyTopic.java (rev 0) +++ modules/jms/branches/simple-forwarding/impl/src/test/java/org/jboss/seam/jms/test/bridge/simple/MyTopic.java 2010-05-01 00:35:52 UTC (rev 12671) @@ -0,0 +1,12 @@ +package org.jboss.seam.jms.test.bridge.simple; + +import javax.inject.Qualifier; + +import org.jboss.seam.jms.annotations.JmsDestination; + +@Qualifier +@JmsDestination(jndiName="jms/T") +public @interface MyTopic +{ + +} Added: modules/jms/branches/simple-forwarding/impl/src/test/java/org/jboss/seam/jms/test/bridge/simple/SimpleBridgedEventTest.java =================================================================== --- modules/jms/branches/simple-forwarding/impl/src/test/java/org/jboss/seam/jms/test/bridge/simple/SimpleBridgedEventTest.java (rev 0) +++ modules/jms/branches/simple-forwarding/impl/src/test/java/org/jboss/seam/jms/test/bridge/simple/SimpleBridgedEventTest.java 2010-05-01 00:35:52 UTC (rev 12671) @@ -0,0 +1,56 @@ +package org.jboss.seam.jms.test.bridge.simple; + +import javax.enterprise.event.Event; +import javax.inject.Inject; +import javax.jms.Connection; +import javax.jms.JMSException; +import javax.jms.Message; +import javax.jms.MessageConsumer; +import javax.jms.ObjectMessage; +import javax.jms.Session; +import javax.jms.Topic; + +import org.jboss.arquillian.api.Deployment; +import org.jboss.arquillian.junit.Arquillian; +import org.jboss.seam.jms.annotations.Bridged; +import org.jboss.seam.jms.annotations.JmsDestination; +import org.jboss.seam.jms.test.Util; +import org.jboss.shrinkwrap.api.spec.JavaArchive; +import org.junit.Assert; +import org.junit.Test; +import org.junit.runner.RunWith; + +(a)RunWith(Arquillian.class) +public class SimpleBridgedEventTest +{ + @Deployment + public static JavaArchive createDeployment() + { + return Util.createDeployment(SimpleBridgedEventTest.class); + } + + @Inject Connection c; + @Inject Session s; + @Inject @JmsDestination(jndiName="jms/T") Topic t; + + @Inject @Bridged Event<String> event; + + @Test + public void a() + { + + } + + @Test + public void forwardSimpleEvent() throws JMSException + { + String expected = "test"; + MessageConsumer mc = s.createConsumer(t); + c.start(); + event.fire(expected); + Message m = mc.receive(); + Assert.assertTrue(m != null); + Assert.assertTrue(m instanceof ObjectMessage); + Assert.assertEquals(expected, ((ObjectMessage) m).getObject()); + } +} [View Less]

14 years, 10 months

1
0
0 / 0

← Newer
1
...
22
23
24
25
Older →

Jump to page: