Skip to content

Commit

Permalink
Binary indexing (#41)
Browse files Browse the repository at this point in the history
* Committing to test on Vagrant

* Binaries are flushing

* Checkstyle

* Tests

* Removing jsonpath

* Commenting that line back in

* Checking for null attachment
  • Loading branch information
dannylamb authored and ruebot committed May 15, 2017
1 parent 9ca45c8 commit f3895b4
Show file tree
Hide file tree
Showing 12 changed files with 2,253 additions and 135 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -2,30 +2,79 @@
error.maxRedeliveries=5

# Queues for creating a new Fedora resource
create.input.stream=activemq:queue:islandora-indexing-fcrepo-create
create.dead.stream=activemq:queue:islandora-indexing-fcrepo-create-dead
create.output.stream=mock:result
create.rdf.input.stream=activemq:queue:islandora-indexing-fcrepo-create
create.rdf.dead.stream=activemq:queue:islandora-indexing-fcrepo-create-dead
create.rdf.output.stream=mock:result

# Queues for updating an existing Fedora resource
update.input.stream=activemq:queue:islandora-indexing-fcrepo-update
update.dead.stream=activemq:queue:islandora-indexing-fcrepo-update-dead
update.output.stream=mock:result
update.rdf.input.stream=activemq:queue:islandora-indexing-fcrepo-update
update.rdf.dead.stream=activemq:queue:islandora-indexing-fcrepo-update-dead
update.rdf.output.stream=mock:result

# Queues for deleting a Fedora resource
delete.input.stream=activemq:queue:islandora-indexing-fcrepo-delete
delete.dead.stream=activemq:queue:islandora-indexing-fcrepo-delete-dead
delete.output.stream=mock:result
delete.rdf.input.stream=activemq:queue:islandora-indexing-fcrepo-delete
delete.rdf.dead.stream=activemq:queue:islandora-indexing-fcrepo-delete-dead
delete.rdf.output.stream=mock:result

# Queues to map paths using Gemini
map.input.stream=activemq:queue:islandora-indexing-fcrepo-map
map.dead.stream=activemq:queue:islandora-indexing-fcrepo-map-dead
map.rdf.input.stream=activemq:queue:islandora-indexing-fcrepo-map
map.rdf.dead.stream=activemq:queue:islandora-indexing-fcrepo-map-dead

# Queues to unmap paths using Gemini
unmap.input.stream=activemq:queue:islandora-indexing-fcrepo-unmap
unmap.dead.stream=activemq:queue:islandora-indexing-fcrepo-unmap-dead
unmap.rdf.input.stream=activemq:queue:islandora-indexing-fcrepo-unmap
unmap.rdf.dead.stream=activemq:queue:islandora-indexing-fcrepo-unmap-dead

# Urls for all the various services
milliner.baseUrl=http://localhost:8000/milliner/metadata
milliner.baseUrl=http://localhost:8000/milliner
gemini.baseUrl=http://localhost:8000/gemini
drupal.baseUrl=http://localhost:8000
fcrepo.baseUrl=http://localhost:8080/fcrepo/rest

# Queues to create binaries
create.binary.input.stream=activemq:queue:islandora-indexing-fcrepo-binary-create
create.binary.dead.stream=activemq:queue:islandora-indexing-fcrepo-binary-create-dead
create.binary.output.stream=mock:result

# Queues to update binaries
update.binary.input.stream=activemq:queue:islandora-indexing-fcrepo-binary-update
update.binary.dead.stream=activemq:queue:islandora-indexing-fcrepo-binary-update-dead
update.binary.output.stream=mock:result

update.binary.delete.input.stream=activemq:queue:islandora-indexing-fcrepo-binary-update-delete
update.binary.delete.dead.stream=activemq:queue:islandora-indexing-fcrepo-binary-update-delete-dead

update.binary.unmap.input.stream=activemq:queue:islandora-indexing-fcrepo-binary-update-unmap
update.binary.unmap.dead.stream=activemq:queue:islandora-indexing-fcrepo-binary-update-unmap-dead

update.binary.unmap.rdf.input.stream=activemq:queue:islandora-indexing-fcrepo-binary-update-unmap-rdf
update.binary.unmap.rdf.dead.stream=activemq:queue:islandora-indexing-fcrepo-binary-update-unmap-rdf-dead

update.binary.create.input.stream=activemq:queue:islandora-indexing-fcrepo-binary-update-create
update.binary.create.dead.stream=activemq:queue:islandora-indexing-fcrepo-binary-update-create-dead

update.binary.map.input.stream=activemq:queue:islandora-indexing-fcrepo-binary-update-map
update.binary.map.dead.stream=activemq:queue:islandora-indexing-fcrepo-binary-update-map-dead

update.binary.map.rdf.input.stream=activemq:queue:islandora-indexing-fcrepo-binary-update-map-rdf
update.binary.map.rdf.dead.stream=activemq:queue:islandora-indexing-fcrepo-binary-update-map-dead-rdf

# Queues to delete binaries
delete.binary.input.stream=activemq:queue:islandora-indexing-fcrepo-binary-delete
delete.binary.dead.stream=activemq:queue:islandora-indexing-fcrepo-binary-delete-dead
delete.binary.output.stream=mock:result

# Queues to map binaries
map.binary.input.stream=activemq:queue:islandora-indexing-fcrepo-map-binary
map.binary.dead.stream=activemq:queue:islandora-indexing-fcrepo-map-binary-dead

# Queues to unmap binaries
unmap.binary.input.stream=activemq:queue:islandora-indexing-fcrepo-unmap-binary
unmap.binary.dead.stream=activemq:queue:islandora-indexing-fcrepo-unmap-binary-dead

# Queues to map binary descriptions
map.binary.rdf.input.stream=activemq:queue:islandora-indexing-fcrepo-map-binary-rdf
map.binary.rdf.dead.stream=activemq:queue:islandora-indexing-fcrepo-map-binary-rdf-dead

# Queues to unmap binary descriptions
unmap.binary.rdf.input.stream=activemq:queue:islandora-indexing-fcrepo-unmap-binary-rdf
unmap.binary.rdf.dead.stream=activemq:queue:islandora-indexing-fcrepo-unmap-binary-rdf-dead
Original file line number Diff line number Diff line change
@@ -0,0 +1,74 @@
/*
* Licensed to Islandora Foundation under one or more contributor license
* agreements. See the NOTICE file distributed with this work for additional
* information regarding copyright ownership.
*
* The Islandora Foundation licenses this file to you under the MIT License.
* You may not use this file except in compliance with the License.
* You may obtain a copy of the License at
*
* https://opensource.org/licenses/MIT
*
* 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 ca.islandora.alpaca.indexing.fcrepo;

/**
* POJO for an attached file. Part of an AS2Event.
*
* @author Danny Lamb
*/
public class AS2Attachment {

/**
* @return Type of user
*/
public String getType() {
return type;
}

/**
* @param type Type of user
*/
public void setType(final String type) {
this.type = type;
}

/**
* @return URL of the file
*/
public String getUrl() {
return url;
}

/**
* @param url URL of the file
*/
public void setUrl(final String url) {
this.url = url;
}

/**
* @return Mimetype
*/
public String getMediaType() {
return this.mediaType;
}

/**
* @param mediaType Mimetype
*/
public void setMediaType(final String mediaType) {
this.mediaType = mediaType;
}

private String type;
private String url;
private String mediaType;

}
Original file line number Diff line number Diff line change
Expand Up @@ -69,6 +69,20 @@ public void setActor(final AS2Actor actor) {
this.actor = actor;
}

/**
* @return File associated with this event
*/
public AS2Attachment getAttachment() {
return attachment;
}

/**
* @param attachment File associated with this event
*/
public void setAttachment(final AS2Attachment attachment) {
this.attachment = attachment;
}

/**
* @return JSON-LD Context
*/
Expand All @@ -88,5 +102,6 @@ public void setContext(final String context) {
private String type;
private String object;
private AS2Actor actor;
private AS2Attachment attachment;

}
Loading

0 comments on commit f3895b4

Please sign in to comment.