You are viewing a plain text version of this content. The canonical link for it is here.
Posted to wsrf-dev@ws.apache.org by sc...@apache.org on 2005/02/25 18:04:05 UTC
svn commit: r155347 - in
incubator/apollo/trunk/src/site/content/example/src/java/org/oasisOpen/docs/wsrf/x2005/x01/wsrfInterop20Draft03Wsdl:
JobPortHome.java JobPortResource.java JobPortService.java
PrinterPortResource.java PrinterPortService.java
Author: scamp
Date: Fri Feb 25 09:04:04 2005
New Revision: 155347
URL: http://svn.apache.org/viewcvs?view=rev&rev=155347
Log: (empty)
Modified:
incubator/apollo/trunk/src/site/content/example/src/java/org/oasisOpen/docs/wsrf/x2005/x01/wsrfInterop20Draft03Wsdl/JobPortHome.java
incubator/apollo/trunk/src/site/content/example/src/java/org/oasisOpen/docs/wsrf/x2005/x01/wsrfInterop20Draft03Wsdl/JobPortResource.java
incubator/apollo/trunk/src/site/content/example/src/java/org/oasisOpen/docs/wsrf/x2005/x01/wsrfInterop20Draft03Wsdl/JobPortService.java
incubator/apollo/trunk/src/site/content/example/src/java/org/oasisOpen/docs/wsrf/x2005/x01/wsrfInterop20Draft03Wsdl/PrinterPortResource.java
incubator/apollo/trunk/src/site/content/example/src/java/org/oasisOpen/docs/wsrf/x2005/x01/wsrfInterop20Draft03Wsdl/PrinterPortService.java
Modified: incubator/apollo/trunk/src/site/content/example/src/java/org/oasisOpen/docs/wsrf/x2005/x01/wsrfInterop20Draft03Wsdl/JobPortHome.java
URL: http://svn.apache.org/viewcvs/incubator/apollo/trunk/src/site/content/example/src/java/org/oasisOpen/docs/wsrf/x2005/x01/wsrfInterop20Draft03Wsdl/JobPortHome.java?view=diff&r1=155346&r2=155347
==============================================================================
--- incubator/apollo/trunk/src/site/content/example/src/java/org/oasisOpen/docs/wsrf/x2005/x01/wsrfInterop20Draft03Wsdl/JobPortHome.java (original)
+++ incubator/apollo/trunk/src/site/content/example/src/java/org/oasisOpen/docs/wsrf/x2005/x01/wsrfInterop20Draft03Wsdl/JobPortHome.java Fri Feb 25 09:04:04 2005
@@ -29,6 +29,8 @@
import org.xmlsoap.schemas.ws.x2004.x08.addressing.ReferencePropertiesType;
import javax.xml.namespace.QName;
import java.io.Serializable;
+import java.util.List;
+import java.util.ArrayList;
/**
* Home for JobPort WS-Resources.
@@ -44,7 +46,9 @@
JndiConstants.CONTEXT_NAME_SERVICES + "/" + SERVICE_NAME + "/" + JndiConstants.ATOMIC_NAME_HOME;
private long m_jobId = 0;
- /**
+
+
+ /**
* DOCUMENT_ME
*
* @param key DOCUMENT_ME
@@ -106,7 +110,7 @@
* @param origUserName DOCUMENT_ME
* @param documentFormat DOCUMENT_ME
* @param base64Data DOCUMENT_ME
- * @param epr DOCUMENT_ME
+ * @param printerResource DOCUMENT_ME
*
* @return DOCUMENT_ME
*/
@@ -115,7 +119,7 @@
String origUserName,
MimeMediaTypeType.Enum documentFormat,
byte[] base64Data,
- EndpointReferenceType epr )
+ PrinterPortResource printerResource )
{
++m_jobId; //todo generate a job id.....counter?
SimpleTypeResourceKey key =
@@ -123,9 +127,9 @@
Long.toString( m_jobId ) );
EndpointReferenceType jobEpr = getEprForResource( key,
resourceContext.getBaseURL( ) );
- JobPortResource job = new JobPortResource( jobEpr, m_jobId, jobName, origUserName, epr );
+ JobPortResource job = new JobPortResource( jobEpr, m_jobId, jobName, origUserName, printerResource );
job.init( );
- add( key, job );
+ add( key, job );
return job;
}
@@ -134,13 +138,13 @@
*
* @param resourceContext DOCUMENT_ME
* @param jobName DOCUMENT_ME
- * @param epr DOCUMENT_ME
+ * @param printerResource DOCUMENT_ME
*
* @return DOCUMENT_ME
*/
public JobPortResource createJob( ResourceContext resourceContext,
String jobName,
- EndpointReferenceType epr )
+ PrinterPortResource printerResource )
{
++m_jobId;
SimpleTypeResourceKey key =
@@ -148,7 +152,7 @@
"Job" + Integer.toString( (int) m_jobId ) );
EndpointReferenceType jobEpr = getEprForResource( key,
resourceContext.getBaseURL( ) );
- JobPortResource job = new JobPortResource( jobEpr, m_jobId, jobName, epr );
+ JobPortResource job = new JobPortResource( jobEpr, m_jobId, jobName, printerResource );
job.init( );
add( key, job );
return job;
Modified: incubator/apollo/trunk/src/site/content/example/src/java/org/oasisOpen/docs/wsrf/x2005/x01/wsrfInterop20Draft03Wsdl/JobPortResource.java
URL: http://svn.apache.org/viewcvs/incubator/apollo/trunk/src/site/content/example/src/java/org/oasisOpen/docs/wsrf/x2005/x01/wsrfInterop20Draft03Wsdl/JobPortResource.java?view=diff&r1=155346&r2=155347
==============================================================================
--- incubator/apollo/trunk/src/site/content/example/src/java/org/oasisOpen/docs/wsrf/x2005/x01/wsrfInterop20Draft03Wsdl/JobPortResource.java (original)
+++ incubator/apollo/trunk/src/site/content/example/src/java/org/oasisOpen/docs/wsrf/x2005/x01/wsrfInterop20Draft03Wsdl/JobPortResource.java Fri Feb 25 09:04:04 2005
@@ -34,28 +34,32 @@
private String m_origUserName;
private EndpointReferenceType m_jobRef;
private EndpointReferenceType m_printerRef;
+ private boolean m_isReady = false;
+ private PrinterPortResource m_printerResource;
- /**
+
+ /**
* Creates a new {@link JobPortResource} object.
*
* @param jobEpr DOCUMENT_ME
* @param jobId DOCUMENT_ME
* @param jobName DOCUMENT_ME
* @param origUserName DOCUMENT_ME
- * @param printerRef DOCUMENT_ME
+ * @param printerResource DOCUMENT_ME
*/
public JobPortResource( EndpointReferenceType jobEpr,
long jobId,
String jobName,
String origUserName,
- EndpointReferenceType printerRef )
+ PrinterPortResource printerResource )
{
super( );
m_jobName = jobName;
m_jobId = jobId;
m_origUserName = origUserName;
m_jobRef = jobEpr;
- m_printerRef = printerRef;
+ m_printerResource = printerResource;
+ m_printerRef = printerResource.getEpr();
}
/**
@@ -64,18 +68,19 @@
* @param jobEpr DOCUMENT_ME
* @param jobId DOCUMENT_ME
* @param jobName DOCUMENT_ME
- * @param epr DOCUMENT_ME
+ * @param printerResource DOCUMENT_ME
*/
public JobPortResource( EndpointReferenceType jobEpr,
long jobId,
String jobName,
- EndpointReferenceType epr )
+ PrinterPortResource printerResource )
{
super( );
m_jobId = jobId;
m_jobName = jobName;
m_jobRef = jobEpr;
- m_printerRef = epr;
+ m_printerResource = printerResource;
+ m_printerRef = printerResource.getEpr();
}
/**
@@ -129,4 +134,15 @@
{
return m_jobRef;
}
+
+ public boolean isQueued() {
+ return m_isReady;
+ }
+
+ public void enqueue()
+ {
+ m_isReady = true;
+ m_printerResource.addJobToQueue(this);
+ }
+
}
Modified: incubator/apollo/trunk/src/site/content/example/src/java/org/oasisOpen/docs/wsrf/x2005/x01/wsrfInterop20Draft03Wsdl/JobPortService.java
URL: http://svn.apache.org/viewcvs/incubator/apollo/trunk/src/site/content/example/src/java/org/oasisOpen/docs/wsrf/x2005/x01/wsrfInterop20Draft03Wsdl/JobPortService.java?view=diff&r1=155346&r2=155347
==============================================================================
--- incubator/apollo/trunk/src/site/content/example/src/java/org/oasisOpen/docs/wsrf/x2005/x01/wsrfInterop20Draft03Wsdl/JobPortService.java (original)
+++ incubator/apollo/trunk/src/site/content/example/src/java/org/oasisOpen/docs/wsrf/x2005/x01/wsrfInterop20Draft03Wsdl/JobPortService.java Fri Feb 25 09:04:04 2005
@@ -83,13 +83,19 @@
sendDocumentRequest.getDocumentFormat( );
boolean lastDocument =
sendDocumentRequest.getLastDocument( );
+
try
{
if ( isDocTypeSupported( documentFormat ) )
{
JobPortResource jobResource =
(JobPortResource) getResourceContext( ).getResource( );
- org.apache.ws.resource.properties.ResourcePropertySet resourcePropertySet =
+
+ if (lastDocument)
+ {
+ jobResource.enqueue();
+ }
+ org.apache.ws.resource.properties.ResourcePropertySet resourcePropertySet =
jobResource.getResourcePropertySet( );
//todo ok this just means we add to document to be printed...need some representation or something
Modified: incubator/apollo/trunk/src/site/content/example/src/java/org/oasisOpen/docs/wsrf/x2005/x01/wsrfInterop20Draft03Wsdl/PrinterPortResource.java
URL: http://svn.apache.org/viewcvs/incubator/apollo/trunk/src/site/content/example/src/java/org/oasisOpen/docs/wsrf/x2005/x01/wsrfInterop20Draft03Wsdl/PrinterPortResource.java?view=diff&r1=155346&r2=155347
==============================================================================
--- incubator/apollo/trunk/src/site/content/example/src/java/org/oasisOpen/docs/wsrf/x2005/x01/wsrfInterop20Draft03Wsdl/PrinterPortResource.java (original)
+++ incubator/apollo/trunk/src/site/content/example/src/java/org/oasisOpen/docs/wsrf/x2005/x01/wsrfInterop20Draft03Wsdl/PrinterPortResource.java Fri Feb 25 09:04:04 2005
@@ -22,17 +22,22 @@
import java.util.ArrayList;
import java.util.List;
+import commonj.timers.TimerListener;
+import commonj.timers.Timer;
+
/**
* A PrinterPort WS-Resource.
* <p/>
* NOTE: This class is generated but IS meant to be modified.
*/
public class PrinterPortResource
- extends AbstractPrinterPortResource
+ extends AbstractPrinterPortResource implements TimerListener
{
private String m_name;
private EndpointReferenceType m_epr;
+ private List m_printQueue = new ArrayList();
+
/**
* Creates a new {@link PrinterPortResource} object.
*
@@ -105,4 +110,13 @@
mimeMediaTypes.addMimeMediaType( MimeMediaTypeType.TEXT_PLAIN );
resourceProperty.add( documentFormatSupportedDocument );
}
+
+ public void addJobToQueue(JobPortResource job)
+ {
+ m_printQueue.add(job);
+ }
+
+ public void timerExpired(Timer timer) {
+
+ }
}
Modified: incubator/apollo/trunk/src/site/content/example/src/java/org/oasisOpen/docs/wsrf/x2005/x01/wsrfInterop20Draft03Wsdl/PrinterPortService.java
URL: http://svn.apache.org/viewcvs/incubator/apollo/trunk/src/site/content/example/src/java/org/oasisOpen/docs/wsrf/x2005/x01/wsrfInterop20Draft03Wsdl/PrinterPortService.java?view=diff&r1=155346&r2=155347
==============================================================================
--- incubator/apollo/trunk/src/site/content/example/src/java/org/oasisOpen/docs/wsrf/x2005/x01/wsrfInterop20Draft03Wsdl/PrinterPortService.java (original)
+++ incubator/apollo/trunk/src/site/content/example/src/java/org/oasisOpen/docs/wsrf/x2005/x01/wsrfInterop20Draft03Wsdl/PrinterPortService.java Fri Feb 25 09:04:04 2005
@@ -90,7 +90,7 @@
String jobName = createJobRequest.getJobName( );
jobResource = (JobPortResource) home.createJob( getResourceContext( ),
jobName,
- getResourceEpr( ) );
+ (PrinterPortResource)getResourceContext().getResource() );
Calendar currentTime = jobResource.getCurrentTime( );
Calendar termTime = Calendar.getInstance( );
termTime.set( currentTime.get( Calendar.YEAR ),
@@ -110,7 +110,7 @@
}
else
{
- //throw custom client fault
+ //todo throw custom spec-defined fault
}
return responseDocument;
@@ -151,14 +151,15 @@
"",
documentFormat,
base64Data,
- getResourceEpr( ) );
+ (PrinterPortResource)getResourceContext().getResource() );
addJobPropsToPrinterProps( jobResource );
incrementQueueCount( );
addJobInfoToResponse( jobResource, creationResponse );
+ jobResource.enqueue();//add to queue
}
else
{
- //throw some exception custom client
+ //todo throw custom spec-defined fault
}
}
catch ( Exception e )
@@ -168,9 +169,10 @@
}
else
{
- //throw custom fault
+ //todo throw custom spec-defined fault
}
+
return responseDocument;
}
@@ -183,7 +185,7 @@
}
catch ( Exception e )
{
- //todo throw custom exception
+ //todo throw custom spec-defined fault
}
XmlBeansResourceProperty resourceProperty =
---------------------------------------------------------------------
To unsubscribe, e-mail: apollo-dev-unsubscribe@ws.apache.org
For additional commands, e-mail: apollo-dev-help@ws.apache.org