public DefaultBlobUploadStrategy(BlobTransferPolicy transferPolicy) 
{
        this.transferPolicy = transferPolicy;
}

 protected URL createUploadURL(ActiveMQBlobMessage message) throws JMSException, MalformedURLException 
{
        return new URL(transferPolicy.getUploadUrl() + message.getMessageId().toString());
}

 public  void deleteFile(ActiveMQBlobMessage message) throws IOException, JMSException 
{
        URL url = createUploadURL(message);
        HttpURLConnection connection = (HttpURLConnection)url.openConnection();
        connection.setRequestMethod("DELETE");
        connection.connect();
        connection.disconnect();
        if (!isSuccessfulCode(connection.getResponseCode())) {
            throw new IOException("DELETE was not successful: " + connection.getResponseCode() + " "
                                  + connection.getResponseMessage());
        }
}

 public URL uploadFile(ActiveMQBlobMessage message,
    File file) throws JMSException, IOException 
{
        return uploadStream(message, new FileInputStream(file));
}

 public URL uploadStream(ActiveMQBlobMessage message,
    InputStream fis) throws JMSException, IOException 
{
        URL url = createUploadURL(message);
        HttpURLConnection connection = (HttpURLConnection)url.openConnection();
        connection.setRequestMethod("PUT");
        connection.setDoOutput(true);
        // use chunked mode or otherwise URLConnection loads everything into
        // memory
        // (chunked mode not supported before JRE 1.5)
        connection.setChunkedStreamingMode(transferPolicy.getBufferSize());
        OutputStream os = connection.getOutputStream();
        byte[] buf = new byte[transferPolicy.getBufferSize()];
        for (int c = fis.read(buf); c != -1; c = fis.read(buf)) {
            os.write(buf, 0, c);
            os.flush();
        }
        os.close();
        fis.close();
        if (!isSuccessfulCode(connection.getResponseCode())) {
            throw new IOException("PUT was not successful: " + connection.getResponseCode() + " "
                                  + connection.getResponseMessage());
        }
        return url;
}