Posts

Showing posts from August, 2008

Embeddable/Distributable JMS

Getting Started with JMS
Apache ActiveMQ
Supported Protocols and URIs
Apache ActiveMQ API
EE 1.4 API
EE 5 API

Round trip topic and queue producer and consumer JUnit example code


import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNotNull;
import static org.junit.Assert.assertNotSame;

import javax.jms.JMSException;
import javax.jms.MapMessage;
import javax.jms.Message;
import javax.jms.MessageListener;
import javax.jms.Queue;
import javax.jms.QueueConnection;
import javax.jms.QueueReceiver;
import javax.jms.QueueSender;
import javax.jms.QueueSession;
import javax.jms.Session;
import javax.jms.TextMessage;
import javax.jms.Topic;
import javax.jms.TopicConnection;
import javax.jms.TopicPublisher;
import javax.jms.TopicSession;
import javax.jms.TopicSubscriber;

import org.apache.activemq.ActiveMQConnectionFactory;
import org.apache.activemq.broker.BrokerService;
import org.junit.After;
import org.junit.Before;
import org.junit.Test;


public class TestMessaging {

private final String host…

SGE

SGE download page
Grid Engine on Windows
DRMAA Java binding API
DRMAA Java binding examples
SGE info blog

Windows can't be used as an SGE Master, only as a compute node
Windows requires SUA/SFU to run SGE
On Windows, can't run DRMAA Java binding API and submit jobs, could create a proxy to linux/unix system.
SGE Master must be run on linux/unix based system


SessionFactory factory = SessionFactory.getFactory ();
Session session = factory.getSession ();
//getContact() returns comma delimited list of DRMs
final String contacts = session.getContact();
final String contact = //select one from list
session.init(contact);
String id = session.runJob(JobTemplate);

Memory Analyzer